diff --git a/src/index.ts b/src/index.ts
index d1494766..e615b5bb 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -2736,6 +2736,8 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements Initiali
     metrics.cacheSize.set({ cache: 'fanout' }, this.fanout.size)
     // Bounded by peer
     metrics.cacheSize.set({ cache: 'peers' }, this.peers.size)
+    metrics.cacheSize.set({ cache: 'streamsOutbound' }, this.streamsOutbound.size)
+    metrics.cacheSize.set({ cache: 'streamsInbound' }, this.streamsInbound.size)
     metrics.cacheSize.set({ cache: 'acceptFromWhitelist' }, this.acceptFromWhitelist.size)
     metrics.cacheSize.set({ cache: 'gossip' }, this.gossip.size)
     metrics.cacheSize.set({ cache: 'control' }, this.control.size)
diff --git a/src/stream.ts b/src/stream.ts
index 3b0b103e..db8f6870 100644
--- a/src/stream.ts
+++ b/src/stream.ts
@@ -33,6 +33,8 @@ export class OutboundStream {
 
   close(): void {
     this.closeController.abort()
+    // similar to pushable.end() but clear the internal buffer
+    this.pushable.return()
     this.rawStream.close()
   }
 }