implement the new network.MuxedConn interface

Author: marten-seemann

conn.go

@@ -3,12 +3,15 @@ package peerstream_multiplex
 import (
 	"context"
 
-	"github.com/libp2p/go-libp2p-core/mux"
+	"github.com/libp2p/go-libp2p-core/network"
+
 	mp "github.com/libp2p/go-mplex"
 )
 
 type conn mp.Multiplex
 
+var _ network.MuxedConn = &conn{}
+
 func (c *conn) Close() error {
 	return c.mplex().Close()
 }
@@ -18,7 +21,7 @@ func (c *conn) IsClosed() bool {
 }
 
 // OpenStream creates a new stream.
-func (c *conn) OpenStream(ctx context.Context) (mux.MuxedStream, error) {
+func (c *conn) OpenStream(ctx context.Context) (network.MuxedStream, error) {
 	s, err := c.mplex().NewStream(ctx)
 	if err != nil {
 		return nil, err
@@ -27,7 +30,7 @@ func (c *conn) OpenStream(ctx context.Context) (mux.MuxedStream, error) {
 }
 
 // AcceptStream accepts a stream opened by the other side.
-func (c *conn) AcceptStream() (mux.MuxedStream, error) {
+func (c *conn) AcceptStream() (network.MuxedStream, error) {
 	s, err := c.mplex().Accept()
 	if err != nil {
 		return nil, err
@@ -38,5 +41,3 @@ func (c *conn) AcceptStream() (mux.MuxedStream, error) {
 func (c *conn) mplex() *mp.Multiplex {
 	return (*mp.Multiplex)(c)
 }
-
-var _ mux.MuxedConn = &conn{}

go.mod

@@ -3,7 +3,7 @@ module github.com/libp2p/go-libp2p-mplex
 go 1.16
 
 require (
-	github.com/libp2p/go-libp2p-core v0.8.0
-	github.com/libp2p/go-libp2p-testing v0.4.0
-	github.com/libp2p/go-mplex v0.3.0
+	github.com/libp2p/go-libp2p-core v0.14.0
+	github.com/libp2p/go-libp2p-testing v0.7.0
+	github.com/libp2p/go-mplex v0.3.1-0.20220117112902-3f6e5a4adc58
 )