fix: use unidirectional streams (#46)

libp2p · Jun 3, 2020 · ec82f5b · ec82f5b
1 parent 3d4fd92
commit ec82f5b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/index.js b/src/index.js
@@ -178,7 +178,6 @@ class PubsubBaseProtocol extends EventEmitter {
 
     const peer = this._addPeer(new Peer(peerInfo))
 
-    peer.attachConnection(stream)
     this._processMessages(idB58Str, stream, peer)
   }
 
@@ -196,7 +195,6 @@ class PubsubBaseProtocol extends EventEmitter {
     try {
       const { stream } = await conn.newStream(this.multicodecs)
       peer.attachConnection(stream)
-      this._processMessages(idB58Str, stream, peer)
     } catch (err) {
       this.log.err(err)
     }

diff --git a/src/peer.js b/src/peer.js
@@ -82,6 +82,8 @@ class Peer extends EventEmitter {
     this.conn = conn
     this.stream = pushable({
       onEnd: () => {
+        // close readable side of the stream
+        this.conn.reset && this.conn.reset()
         this.conn = null
         this.stream = null
         this.emit('close')