From 4be79a4820b8204c10c906c225606dd4e98799f0 Mon Sep 17 00:00:00 2001
From: Roland Kuhn <rk@rkuhn.info>
Date: Fri, 4 Feb 2022 15:27:43 +0100
Subject: [PATCH] prevent receive gap

---
 src/connection.rs | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/connection.rs b/src/connection.rs
index 68e31870..05689203 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -632,10 +632,14 @@ impl<T: AsyncRead + AsyncWrite + Unpin> Connection<T> {
                     }
                     Action::Reset(f) => {
                         log::trace!("{}/{}: sending reset", self.id, f.header().stream_id());
+                        // prevent reception of further frames, since we already rejected data
+                        self.streams.remove(&f.header().stream_id());
                         self.socket.feed(f.into()).await.or(Err(ConnectionError::Closed))?
                     }
                     Action::Terminate(f) => {
                         log::trace!("{}: sending term", self.id);
+                        // prevent reception of further frames, since we already rejected data
+                        self.streams.remove(&f.header().stream_id());
                         self.socket.feed(f.into()).await.or(Err(ConnectionError::Closed))?
                     }
                 }