transport

type PoolConfig struct {
	MaxIdle     int           // maximum idle streams to keep in pool
	IdleTimeout time.Duration // max time a stream can be idle before eviction
	Enabled     bool          // whether pool is enabled
}

type Stream interface {
	io.ReadWriteCloser
	ID() string
	SetID(id string)
	Send(msg protocol.Parsable) error
	Receive() (*protocol.Message, error)

	SetSubdomain(subdomain string)

	Read(p []byte) (n int, err error)
	Write(p []byte) (n int, err error)
	CloseWrite() error
	Context() context.Context
}

type StreamHandler func(stream *quic.Stream) error

type Transport interface {
	Addr() string
	Close()
	Acquire() (Stream, error)
	Release(stream Stream) error
	AcceptStream(ctx context.Context) (Stream, error)
	Len() int
	LenActive(subdomain ...string) int
	Root() Stream
	IsClosed() bool

	ImServer() bool
}