Struct ReplySink 

pub struct ReplySink<R> { /* private fields */ }

One-shot reply target for a command.

Consumed exactly once via Self::send; the closure performs the backend-specific delivery (socket: serialize and write to the peer fd; binder: send through a oneshot channel to the blocked transaction thread).

Implementations

impl<R> ReplySink<R>

pub fn new( send: impl FnOnce(R) -> Result<(), CoreError> + Send + 'static, ) -> Self

Wrap a delivery closure as a reply sink.

pub fn send(self, reply: R) -> Result<(), CoreError>

Deliver the reply, consuming the sink.

Errors

Returns the backend’s delivery error (e.g. the peer went away); the caller may log it and drop the sink.

Drop semantics

Dropping a ReplySink without calling Self::send loses the reply (the closure is dropped). For a Binder backend the waiting transaction thread observes the oneshot disconnect and errors out; the socket backend simply never writes.

Trait Implementations

impl<R> Debug for ReplySink<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.