fix: do not send duplicate close read/write (#1935)

Check the stream timeline for closeWrite/closeRead to make sure we don't send multiple close messages.
libp2p · Aug 5, 2023 · 446fff8 · 446fff8
1 parent 55e1230
commit 446fff8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/packages/interface/src/stream-muxer/stream.ts b/packages/interface/src/stream-muxer/stream.ts
@@ -271,7 +271,7 @@ export abstract class AbstractStream implements Stream {
       this.streamSource.end()
     }
 
-    if (this.status !== 'reset' && this.status !== 'aborted') {
+    if (this.status !== 'reset' && this.status !== 'aborted' && this.timeline.closeRead == null) {
       this.log.trace('send close read to remote')
       await this.sendCloseRead(options)
     }
@@ -308,7 +308,7 @@ export abstract class AbstractStream implements Stream {
       })
     }
 
-    if (this.status !== 'reset' && this.status !== 'aborted') {
+    if (this.status !== 'reset' && this.status !== 'aborted' && this.timeline.closeWrite == null) {
       this.log.trace('send close write to remote')
       await this.sendCloseWrite(options)
     }