Skip to main content

Module streaming

Module streaming 

Source
Available on crate feature server only.
Expand description

Borrowed streaming primitives handed to service methods.

RequestStream decodes inbound request messages from a boxed reader — the request body during run() (via GrpcServerConn::requests), and continues against the same retained body after a bidi upgrade. Channel is the bidirectional read+write surface a bidi responder drives over the upgraded transport.

Codec is type-erased into fn pointers so these user-facing types carry no codec parameter.

Structs§

Channel
Bidirectional channel: read decoded requests, write framed responses, over the upgraded transport.
RequestStream
A stream of decoded request messages.