Merge pull request #21 from libp2p/open-stream-context

change OpenStream to accept a context
libp2p · Dec 19, 2020 · 6c57248 · 6c57248
2 parents fdb9a0a + c2feedf
commit 6c57248
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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