Struct Streaming 

pub struct Streaming {
    pub headers: Metadata,
    /* private fields */
}

An in-flight response stream.

Backpressure is real and needs no code here: the body replenishes the HTTP/2 receive window only as it is polled, so a consumer that stops reading stops the server rather than filling memory. That is the same guarantee the TypeScript client gets, and for the same reason — it is HTTP/2 doing its job.

Fields

headers: Metadata

Initial metadata, available as soon as the stream opens.

Implementations

impl Streaming

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

The next response message, or None once the stream ends.

After None, call Streaming::status for how it ended — a stream that finishes cleanly still has a status, and it is not always OK.

pub fn status(&self) -> Status

The terminal status. Only meaningful once Streaming::message has returned None; before that the trailers have not arrived.

pub async fn finish(&mut self) -> Status

Drain to the end and return the terminal status.

Trait Implementations

impl Debug for Streaming

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.