Struct ServerStreamingCall 

pub struct ServerStreamingCall<T> { /* private fields */ }

Receiving half of a server-streaming or bidirectional client call.

Implementations

impl<T: 'static> ServerStreamingCall<T>

pub fn new<D: StreamDriver<Receive = T> + 'static>(driver: D) -> Self

Wraps a call whose unary request was sent and half-closed by its driver.

pub fn try_recv_next(&mut self) -> Result<Option<T>, StreamError>

Performs one nonblocking receive attempt.

Errors

Returns pending or the sticky terminal failure; EOF is Ok(None).

pub fn recv_next(&mut self) -> Result<Option<T>, StreamError>

Receives the next message, waiting for readiness on the caller thread.

Errors

Returns a terminal RPC, transport or deadline failure.

pub fn finish(&mut self) -> Result<Vec<T>, StreamError>

Drains and returns remaining messages through validated completion.

Errors

Returns a terminal failure, including missing successful trailers.

pub fn initial_metadata(&self) -> Result<Option<Metadata>, StreamError>

Copies received initial metadata, if available.

Errors

Rejects reentrant access from a driver callback.

pub fn trailing_metadata(&self) -> Result<Option<Metadata>, StreamError>

Copies terminal metadata, including on a remote failure.

Errors

Rejects reentrant access from a driver callback.

pub fn cancel(&mut self) -> Result<(), StreamError>

Cancels local resources without waiting for peer acknowledgement.

Errors

Rejects reentrant access from a driver callback.