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 Handler<DriverReplySink> for Box<dyn ErasedHandler>

fn retry_policy(&self, method_id: MethodId) -> RetryPolicy

Return the static retry policy for a method ID served by this handler.

fn args_have_channels(&self, method_id: MethodId) -> bool

Return whether the method’s argument shape contains any channels.

fn response_wire_shape(&self, method_id: MethodId) -> Option<&'static Shape>

Return the canonical wire response shape for a method, if known.

async fn handle( &self, call: SelfRef<RequestCall<'static>>, reply: DriverReplySink, schemas: Arc<SchemaRecvTracker>, )

Dispatch an incoming call to the appropriate method implementation.

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 request_id(&self) -> Option<RequestId>

Return the wire-level request identifier for this reply sink when available.

fn connection_id(&self) -> Option<ConnectionId>

Return the virtual connection identifier for this reply sink when available.

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>>.