change OpenStream to accept a context

libp2p · Dec 17, 2020 · d4309a8 · d4309a8
1 parent c2e7d8a
commit d4309a8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/conn.go b/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