From a920757f7e8d15d4bb999eb70506e49ba9c84ecb Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sat, 19 Aug 2017 14:25:42 +0700 Subject: [PATCH] remove conn.Serve --- p2p/muxer/mplex/multiplex.go | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/p2p/muxer/mplex/multiplex.go b/p2p/muxer/mplex/multiplex.go index 77227ccf25..0eebb7262f 100644 --- a/p2p/muxer/mplex/multiplex.go +++ b/p2p/muxer/mplex/multiplex.go @@ -1,15 +1,12 @@ package peerstream_multiplex import ( - "errors" "net" smux "github.com/libp2p/go-stream-muxer" mp "github.com/whyrusleeping/go-multiplex" // Conn is a connection to a remote peer. ) -var ErrUseServe = errors.New("not implemented, use Serve") - type conn struct { *mp.Multiplex } @@ -32,18 +29,6 @@ func (c *conn) AcceptStream() (smux.Stream, error) { return c.Multiplex.Accept() } -// Serve starts listening for incoming requests and handles them -// using given StreamHandler -func (c *conn) Serve(handler smux.StreamHandler) { - for { - s, err := c.AcceptStream() - if err != nil { - return - } - go handler(s) - } -} - // Transport is a go-peerstream transport that constructs // multiplex-backed connections. type Transport struct{}