MessageStream

Type Alias MessageStream 

Source
pub type MessageStream = Pin<Box<dyn Stream<Item = Result<Bytes, Status>> + Send>>;
Expand description

Type alias for a stream of protobuf message bytes

Used for both client streaming (incoming) and server streaming (outgoing). Each item in the stream is either:

  • Ok(Bytes): A serialized protobuf message
  • Err(Status): A gRPC error

Aliased Typeยง

pub struct MessageStream { /* private fields */ }