fix: call connection.addStream properly

libp2p · Feb 5, 2020 · cc54d50 · cc54d50
1 parent 850b5c9
commit cc54d50
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/upgrader.js b/src/upgrader.js
@@ -231,8 +231,8 @@ class Upgrader {
             const { stream, protocol } = await mss.handle(Array.from(this.protocols.keys()))
             log('%s: incoming stream opened on %s', direction, protocol)
             if (this.metrics) this.metrics.trackStream({ stream, remotePeer, protocol })
-            connection.addStream(stream, protocol)
-            this._onStream({ connection, stream, protocol })
+            connection.addStream(muxedStream, { protocol })
+            this._onStream({ connection, stream: muxedStream, protocol })
           } catch (err) {
             log.error(err)
           }