Struct StreamingResponse 

pub struct StreamingResponse {
    pub inner: Streaming<ResponseMessage>,
}

Streaming requests and responses.

Fields

inner: Streaming<ResponseMessage>

Implementations

impl StreamingResponse

pub fn new(inner: Streaming<ResponseMessage>) -> Self

Methods from Deref<Target = Streaming<ResponseMessage>>

pub async fn message(&mut self) -> Result<Option<T>, Status>

Fetch the next message from this stream.

Return value

• Result::Err(val) means a gRPC error was sent by the sender instead of a valid response message. Refer to Status::code and Status::message to examine possible error causes.

• Result::Ok(None) means the stream was closed by the sender and no more messages will be delivered. Further attempts to call Streaming::message will result in the same return value.

• Result::Ok(Some(val)) means the sender streamed a valid response message val.

if let Some(next_message) = request.message().await? {
    println!("{:?}", next_message);
}

pub async fn trailers(&mut self) -> Result<Option<MetadataMap>, Status>

Fetch the trailing metadata.

This will drain the stream of all its messages to receive the trailing metadata. If Streaming::message returns None then this function will not need to poll for trailers since the body was totally consumed.

if let Some(metadata) = request.trailers().await? {
    println!("{:?}", metadata);
}

Trait Implementations

impl Deref for StreamingResponse

type Target = Streaming<ResponseMessage>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for StreamingResponse

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.