transport

type Accepter interface {
	Accept(mc MultiConn) (err error)
}

type MultiConn interface {
	// Context returns the connection context that contains handshake details
	Context() context.Context
	// Accept accepts new sub connections
	Accept() (conn net.Conn, err error)
	// Open opens new sub connection
	Open(ctx context.Context) (conn net.Conn, err error)
	// Addr returns remote peer address
	Addr() string
	// IsClosed returns true when connection is closed
	IsClosed() bool
	// CloseChan returns a channel that will be closed with connection
	CloseChan() <-chan struct{}
	// Close closes the connection and all sub connections
	Close() error
	// BytesRead returns the cumulative number of bytes received from the peer
	// at the transport boundary (post-decryption, post-compression). For yamux
	// this includes session framing on top of the underlying TCP conn; for
	// QUIC/webtransport this counts only stream-level bytes and excludes
	// QUIC/UDP framing overhead.
	BytesRead() int64
	// BytesWritten returns the cumulative number of bytes sent to the peer
	// at the transport boundary (see BytesRead for level-of-detail caveats).
	BytesWritten() int64
}

type Transport interface {
	// SetAccepter sets accepter that will be called for new connections
	// this method should be called before app start
	SetAccepter(accepter Accepter)
	// Dial creates a new connection by given address
	Dial(ctx context.Context, addr string) (mc MultiConn, err error)
}