Struct DriverReplySink 

pub struct DriverReplySink { /* private fields */ }

Concrete ReplySink implementation for the driver.

If dropped without send_reply being called, automatically sends VoxError::Cancelled to the caller. This guarantees that every request attempt receives exactly one terminal response (rpc.response.one-per-request), even if the handler panics or forgets to reply.

Trait Implementations

impl Drop for DriverReplySink

fn drop(&mut self)

Executes the destructor for this type.

impl ReplySink for DriverReplySink

async fn send_reply(self, response: RequestResponse<'_>)

Send the terminal response for this request attempt, consuming the sink. Any error that happens during send_reply must set a flag in the driver for it to resolve the attempt as failed.

fn channel_binder(&self) -> Option<&dyn ChannelBinder>

Return a channel binder for binding Tx/Rx handles in deserialized args.

fn send_error<E>( self, error: VoxError<E>, ) -> impl Future<Output = ()> + MaybeSend

where E: for<'a> Facet<'a> + MaybeSend, Self: Sized,

Send an error response for this request attempt, consuming the sink.

fn send_typed_error<'wire, T, E>( self, error: VoxError<E>, ) -> impl Future<Output = ()> + MaybeSend

where Self: Sized, T: Facet<'wire> + MaybeSend, E: Facet<'wire> + MaybeSend,

Send an error response using the full wire shape Result<T, VoxError<E>>.