Skip to content

GitLab

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

change OpenStream to accept a context

parent afea2aff
Hide whitespace changes
Inline Side-by-side
Showing with 9 additions and 7 deletions
conn.go
View file @ d06bf7b9
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
......
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