fix: destroy streams on end (#86)

libp2p · Mar 25, 2019 · 4b1ebc7 · 4b1ebc7
1 parent 20198d1
commit 4b1ebc7
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/muxer.js b/src/muxer.js
@@ -39,7 +39,6 @@ module.exports = class Muxer extends EventEmitter {
       if (didError && /ok/i.test(didError.message)) {
         didError = false
       }
-      spdy.destroyStreams(new Error('underlying socket has been closed'))
       this.emit('close', didError)
     })
 
@@ -103,10 +102,9 @@ module.exports = class Muxer extends EventEmitter {
   }
 
   end (cb) {
-    cb = once(cb || noop)
-    this.spdy.once('error', (err) => {
-      cb(err)
-    })
+    cb = cb ? once(cb) : noop
+    this.spdy.once('error', cb)
+    this.spdy.destroyStreams()
     this.spdy.end((err) => {
       if (err && /ok/i.test(err.message)) {
         return cb()