From d916bc65468e4bbc2370086d861f9a49a044be07 Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Thu, 17 Dec 2020 16:12:01 +0700 Subject: [PATCH] change OpenStream to accept a context --- p2p/muxer/yamux/conn.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/p2p/muxer/yamux/conn.go b/p2p/muxer/yamux/conn.go index 6c39cc2035..4301d46633 100644 --- 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