Adding transport.QListener

transport/transport.go

@@ -124,6 +124,9 @@ type Transport interface {
 	// Dial dials a remote peer. It should try to reuse local listener
 	// addresses if possible but it may choose not to.
 	Dial(ctx context.Context, raddr ma.Multiaddr, p peer.ID) (CapableConn, error)
+
+	// Listen listens on the passed multiaddr.
+	Listen(laddr ma.Multiaddr) (Listener, error)
 }
 
 type QTransport interface {
@@ -133,6 +136,9 @@ type QTransport interface {
 	// addresses if possible but it may choose not to.
 	Dial(ctx context.Context, raddr ma.Multiaddr, p peer.ID) (QCapableConn, error)
 
+	// Listen listens on the passed multiaddr.
+	Listen(laddr ma.Multiaddr) (QListener, error)
+
 	// Score returns the Quality we can expect from the connection to this peer.
 	// That must be deterministic and fast.
 	Score(raddr ma.Multiaddr, p peer.ID) (Score, error)
@@ -147,9 +153,6 @@ type BaseTransport interface {
 	// out addresses that we can't dial.
 	CanDial(addr ma.Multiaddr) bool
 
-	// Listen listens on the passed multiaddr.
-	Listen(laddr ma.Multiaddr) (Listener, error)
-
 	// Protocol returns the set of protocols handled by this transport.
 	//
 	// See the Network interface for an explanation of how this is used.
@@ -167,7 +170,20 @@ type BaseTransport interface {
 // package, and also exposes a Multiaddr method as opposed to a regular Addr
 // method
 type Listener interface {
+	BaseListener
+
 	Accept() (CapableConn, error)
+}
+
+// QListener is like listener but produce QCapableConn instead of CapableConn.
+type QListener interface {
+	BaseListener
+
+	Accept() (QCapableConn, error)
+}
+
+// BaseListener is used to build `Lister` and `QListener`
+type BaseListener interface {
 	Close() error
 	Addr() net.Addr
 	Multiaddr() ma.Multiaddr