quic

type Middleware func(next StreamHandler) StreamHandler

type Option func(*Server)

type QuicError interface {
	ErrorCode() uint64
}

type Request struct {
	Address string        `json:"-"`
	Timeout time.Duration `json:"-"`
	Body    json.RawMessage
	Headers map[string]string
}

type Response struct {
	Body    []byte            `json:"body"`
	Headers map[string]string `json:"headers"`
}

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

type Stream interface {
	StreamID() int64
	Read(p []byte) (int, error)
	Write(p []byte) (int, error)
	CancelWrite(errorCode uint64)
	CancelRead(errorCode uint64)
	Context() context.Context
	Close() error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
	SetDeadline(t time.Time) error
}

type StreamHandler interface {
	HandleStream(ctx context.Context, stream Stream) error
}

type StreamHandlerFunc func(ctx context.Context, stream Stream) error