From 92ae2a88730139b6b8e52a3f514f745ad3db3e3b Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sat, 19 Dec 2020 15:07:16 +0700 Subject: [PATCH] update go-mplex, use the context passed to OpenStream --- p2p/muxer/mplex/conn.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/p2p/muxer/mplex/conn.go b/p2p/muxer/mplex/conn.go index 6dd3437648..e07a72c6c0 100644 --- a/p2p/muxer/mplex/conn.go +++ b/p2p/muxer/mplex/conn.go @@ -18,8 +18,8 @@ func (c *conn) IsClosed() bool { } // OpenStream creates a new stream. -func (c *conn) OpenStream(context.Context) (mux.MuxedStream, error) { - s, err := c.mplex().NewStream() +func (c *conn) OpenStream(ctx context.Context) (mux.MuxedStream, error) { + s, err := c.mplex().NewStream(ctx) if err != nil { return nil, err }