Merge pull request #20 from libp2p/feat/stream-interfaces

feat: update stream interfaces

conn.go

@@ -17,12 +17,20 @@ func (c *conn) IsClosed() bool {
 
 // OpenStream creates a new stream.
 func (c *conn) OpenStream() (mux.MuxedStream, error) {
-	return c.mplex().NewStream()
+	s, err := c.mplex().NewStream()
+	if err != nil {
+		return nil, err
+	}
+	return (*stream)(s), nil
 }
 
 // AcceptStream accepts a stream opened by the other side.
 func (c *conn) AcceptStream() (mux.MuxedStream, error) {
-	return c.mplex().Accept()
+	s, err := c.mplex().Accept()
+	if err != nil {
+		return nil, err
+	}
+	return (*stream)(s), nil
 }
 
 func (c *conn) mplex() *mp.Multiplex {

go.mod

@@ -3,11 +3,7 @@ module github.com/libp2p/go-libp2p-mplex
 go 1.12
 
 require (
-	github.com/ipfs/go-log v1.0.4 // indirect
-	github.com/ipfs/go-log/v2 v2.1.1 // indirect
-	github.com/libp2p/go-libp2p-core v0.6.1
-	github.com/libp2p/go-libp2p-testing v0.1.1
-	github.com/libp2p/go-mplex v0.1.2
-	github.com/opentracing/opentracing-go v1.2.0 // indirect
-	go.uber.org/zap v1.15.0 // indirect
+	github.com/libp2p/go-libp2p-core v0.7.0
+	github.com/libp2p/go-libp2p-testing v0.3.0
+	github.com/libp2p/go-mplex v0.2.0
 )