Struct RequestStream 

pub struct RequestStream<Req>(/* private fields */);

Inbound server requests, created together with a response sink by server_streams. Request EOF half-closes inbound messages without closing the response sink.

Implementations

impl<Req: 'static> RequestStream<Req>

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

Wraps inbound requests without treating request EOF as response completion.

Methods from Deref<Target = ServerStreamingCall<Req>>

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.

Trait Implementations

impl<Req> Deref for RequestStream<Req>

type Target = ServerStreamingCall<Req>

The resulting type after dereferencing.

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

Dereferences the value.

impl<Req> DerefMut for RequestStream<Req>

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

Mutably dereferences the value.