Skip to content

GitLab

Commit ffde5c7b authored by Marten Seemann's avatar Marten Seemann
Browse files
Options

update go-yamux to v2.0.0, use context passed to OpenStream

parent 9285cf1c
Hide whitespace changes
Inline Side-by-side
Showing with 8 additions and 8 deletions
conn.go
View file @ ffde5c7b
......@@ -4,7 +4,7 @@ import (
"context"
"github.com/libp2p/go-libp2p-core/mux"
"github.com/libp2p/go-yamux"
"github.com/libp2p/go-yamux/v2"
)
// conn implements mux.MuxedConn over yamux.Session.
......@@ -21,8 +21,8 @@ func (c *conn) IsClosed() bool {
}
// OpenStream creates a new stream.
func (c *conn) OpenStream(context.Context) (mux.MuxedStream, error) {
s, err := c.yamux().OpenStream()
func (c *conn) OpenStream(ctx context.Context) (mux.MuxedStream, error) {
s, err := c.yamux().OpenStream(ctx)
if err != nil {
return nil, err
}
......
stream.go
View file @ ffde5c7b
......@@ -4,7 +4,7 @@ import (
"time"
"github.com/libp2p/go-libp2p-core/mux"
"github.com/libp2p/go-yamux"
"github.com/libp2p/go-yamux/v2"
)
// stream implements mux.MuxedStream over yamux.Stream.
......
transport.go
View file @ ffde5c7b
......@@ -5,7 +5,7 @@ import (
"net"
mux "github.com/libp2p/go-libp2p-core/mux"
yamux "github.com/libp2p/go-yamux"
"github.com/libp2p/go-yamux/v2"
)
var DefaultTransport *Transport
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment