streamwriter

Documentation

Index

• func New[SizeT size, Req any, Resp any](chunkSize SizeT, stream Stream[Req, Resp], req Request[Req]) *writer[SizeT, Req, Resp]
• type Request
• type Stream

Functions

func New

func New[SizeT size, Req any, Resp any](chunkSize SizeT, stream Stream[Req, Resp], req Request[Req]) *writer[SizeT, Req, Resp]

Types

type Request

type Request[T any] func(p []byte) *T

type Stream

type Stream[Req any, Resp any] interface {
	Send(req *Req) error
	CloseAndRecv() (*Resp, error)
}