p2p

type Listener interface {
	Accept() (net.Stream, error)
	Close() error
}

type ListenerInfo struct {
	// Application protocol identifier.
	Protocol string

	// Node identity
	Identity peer.ID

	// Local protocol stream address.
	Address ma.Multiaddr

	// Local protocol stream listener.
	Closer io.Closer

	// Flag indicating whether we're still accepting incoming connections, or
	// whether this application listener has been shutdown.
	Running bool

	Registry *ListenerRegistry
}

type ListenerRegistry struct {
	Listeners []*ListenerInfo
}

type P2P struct {
	Listeners ListenerRegistry
	Streams   StreamRegistry
	// contains filtered or unexported fields
}

type P2PListener struct {
	// contains filtered or unexported fields
}

type StreamInfo struct {
	HandlerID uint64

	Protocol string

	LocalPeer peer.ID
	LocalAddr ma.Multiaddr

	RemotePeer peer.ID
	RemoteAddr ma.Multiaddr

	Local  manet.Conn
	Remote net.Stream

	Registry *StreamRegistry
}

type StreamRegistry struct {
	Streams []*StreamInfo
	// contains filtered or unexported fields
}