Struct ResponseSink 

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

Sending half of a server response stream.

Implementations

impl<T> ResponseSink<T>

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

Sends a message, waiting for transport capacity.

Errors

Returns a closed-direction or terminal failure.

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

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

Errors

Returns pending, closed-direction or terminal failure.

pub fn try_finish( &mut self, status: &Status, trailers: &Metadata, ) -> Result<(), StreamError>

Attempts completion without waiting or consuming trailers on backpressure.

Errors

Returns pending, a terminal error or an already-finished error.

pub fn finish( &mut self, status: Status, trailers: Metadata, ) -> Result<(), StreamError>

Sends final status and trailers, including a trailers-only error response.

Errors

Returns a terminal failure or rejects an already finished RPC.

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.