EncodeResult writes the result code to the output writer.

NewBufLimitReader returns a new Reader whose buffer has the specified size.

StreamChunk takes the (decompressed) response message from the msg io.WriterTo, and writes it as a chunk with given result code to the output writer.

StreamHeaderAndPayload reads a payload and streams (and optionally compresses) it to the writer.

256 bytes max error size.

Reader implements buffering for an io.Reader object.

ReadContextFn reads <context-bytes> from the response stream, and determines the max chunk size for decoding.

RequestPayloadHandler processes a request (decompressed if previously compressed), read from r.

ResponseChunkHandler is a function that processes a response chunk.

ResponseHandler processes a response by internally processing chunks, any error is propagated up.