Struct BidiStreamingCall 

pub struct BidiStreamingCall<Req, Resp> { /* private fields */ }

Independent request and response directions for a bidirectional client call.

Implementations

impl<Req: 'static, Resp: 'static> BidiStreamingCall<Req, Resp>

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

pub fn send(&mut self, value: &Req) -> Result<(), StreamError>

Sends a message, waiting for transport capacity.

Errors

Returns a closed-direction or terminal failure.

pub fn try_send(&mut self, value: &Req) -> Result<(), StreamError>

Attempts a send; pending means the message was not accepted.

Errors

Returns pending, closed-direction or terminal failure.

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

Idempotently half-closes requests while allowing further responses.

Errors

Returns a terminal failure.

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

Attempts request half-close without waiting.

Errors

Returns pending or terminal failure.

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

Receives the next response without blocking.

Errors

Returns pending or sticky terminal failure.

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

Waits for the next response.

Errors

Returns terminal failure.

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

Half-closes requests and returns all remaining responses through completion.

Errors

Returns terminal failure.

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.