Struct DriverReplySink 

pub struct DriverReplySink { /* private fields */ }

Concrete ReplySink implementation for the driver.

If dropped without send_reply being called, automatically sends RoamError::Cancelled to the caller. This guarantees that every request receives exactly one 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 response, consuming the sink. Any error that happens during send_reply must set a flag in the driver for it to reply with an error.

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: RoamError<E>, ) -> impl Future<Output = ()> + MaybeSend

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

Send an error response back to the caller, consuming the sink.