diff --git a/p2p/muxer/mplex/conn.go b/p2p/muxer/mplex/conn.go index 1122e6351c..6dd3437648 100644 --- a/p2p/muxer/mplex/conn.go +++ b/p2p/muxer/mplex/conn.go @@ -1,6 +1,8 @@ package peerstream_multiplex import ( + "context" + "github.com/libp2p/go-libp2p-core/mux" mp "github.com/libp2p/go-mplex" ) @@ -16,7 +18,7 @@ func (c *conn) IsClosed() bool { } // OpenStream creates a new stream. -func (c *conn) OpenStream() (mux.MuxedStream, error) { +func (c *conn) OpenStream(context.Context) (mux.MuxedStream, error) { s, err := c.mplex().NewStream() if err != nil { return nil, err