Merge pull request #23 from libp2p/update-mplex

update go-mplex, use the context passed to OpenStream
libp2p · Dec 19, 2020 · c04213f · c04213f
2 parents 6c57248 + 92ae2a8
commit c04213f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/p2p/muxer/mplex/conn.go b/p2p/muxer/mplex/conn.go
@@ -18,8 +18,8 @@ func (c *conn) IsClosed() bool {
 }
 
 // OpenStream creates a new stream.
-func (c *conn) OpenStream(context.Context) (mux.MuxedStream, error) {
-	s, err := c.mplex().NewStream()
+func (c *conn) OpenStream(ctx context.Context) (mux.MuxedStream, error) {
+	s, err := c.mplex().NewStream(ctx)
 	if err != nil {
 		return nil, err
 	}