Struct ClientStreamingCall 

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

Client-streaming requests with exactly one response after successful completion.

Implementations

impl<Req: 'static, Resp: 'static> ClientStreamingCall<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_finish(&mut self) -> Result<Resp, StreamError>

Advances completion by at most two receive steps, preserving a pending response.

Errors

Returns pending, terminal error, or response cardinality failure.

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

Polls the single response through validated final status.

Errors

Returns the same pending or terminal errors as Self::try_finish.

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

Waits for the single response, then returns EOF on subsequent reads.

Errors

Returns the terminal errors from Self::finish.

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

Waits for exactly one response and a successful final status.

Errors

Returns terminal failure or response cardinality 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.