transport

type Conn interface {
	Write([]byte) (int, error)
	WriteLease(WriteLease) (int, error)
	WriteHeaderAndLease([]byte, WriteLease) (int, error)
	Writev(...[]byte) (int, error)
	Peek([]byte) []byte
	AcquireRead() ReadLease
	Discard(int) (int, error)
	PauseRead()
	ResumeRead()
	ResumeOnNextRead()
	CompleteRequest()
	Close() error
	Context() any
	SetContext(any)
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
}

type Events struct {
	OnOpen  func(Conn)
	OnData  func(Conn) error
	OnClose func(Conn, error)
}

type Option func(*options)

type ReadLease interface {
	Bytes() []byte
	Retain() ReadLease
	Release()
}

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

type WriteLease interface {
	Bytes() []byte
	Retain() WriteLease
	Release()
}