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

feat: update stream interfaces

p2p/muxer/mplex/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 {

p2p/muxer/mplex/stream.go

@@ -32,6 +32,14 @@ func (s *stream) Close() error {
 	return s.mplex().Close()
 }
 
+func (s *stream) CloseWrite() error {
+	return s.mplex().CloseWrite()
+}
+
+func (s *stream) CloseRead() error {
+	return s.mplex().CloseRead()
+}
+
 func (s *stream) Reset() error {
 	return s.mplex().Reset()
 }