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

change OpenStream to accept a context
libp2p · Dec 19, 2020 · 6d4f899 · 6d4f899
2 parents f47682a + d916bc6
commit 6d4f899
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/p2p/muxer/yamux/conn.go b/p2p/muxer/yamux/conn.go
@@ -1,6 +1,8 @@
 package sm_yamux
 
 import (
+	"context"
+
 	"github.com/libp2p/go-libp2p-core/mux"
 	"github.com/libp2p/go-yamux"
 )
@@ -19,7 +21,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.yamux().OpenStream()
 	if err != nil {
 		return nil, err