transport

type Conn interface {
	closer.Closer

	// AcceptStream returns the next stream opened by the peer, blocking until one is available.
	AcceptStream(context.Context) (Stream, error)

	// OpenStream opens a new bidirectional stream.
	// There is no signaling to the peer about new streams.
	// The peer can only accept the stream after data has been sent on it.
	OpenStream(context.Context) (Stream, error)

	// LocalAddr returns the local address.
	LocalAddr() net.Addr

	// RemoteAddr returns the address of the peer.
	RemoteAddr() net.Addr

	// IsClosedError checks whenever the passed error is a closed connection error.
	IsClosedError(error) bool
}

type Listener interface {
	closer.Closer

	// Accept waits for and returns the next connection to the listener.
	// The listener must close the new connection if the listener is closed.
	Accept() (Conn, error)

	// Addr returns the listener's network address.
	Addr() net.Addr
}

type Stream interface {
	net.Conn

	// IsClosed returns true, if the stream has been closed locally or by the remote peer.
	IsClosed() bool

	// ClosedChan returns a closed channel as soon as the stream closes.
	ClosedChan() <-chan struct{}
}

type Transport interface {
	Dial(cl closer.Closer, ctx context.Context, addr string) (Conn, error)
	Listen(cl closer.Closer, addr string) (Listener, error)
}