Struct Reply 

pub struct Reply(/* private fields */);

Where a refusal goes back to.

A command travels socket to desk to worker thread, and only events come back, so a refusal made minutes later has no way home. Making it an event instead would tell everyone watching about one person’s mistyped URL; the city’s history is not anybody’s error log. So the command carries the address of whoever sent it.

Holds a function rather than a channel so that this crate’s public signature does not name a transport the assembly layer would then have to name too.

Implementations

impl Reply

pub fn to(sink: impl Fn(AxError) -> Delivered + Send + Sync + 'static) -> Reply

A reply address that reaches the peer that sent the command.

pub fn nowhere() -> Reply

No peer asked. The schedule starts work by itself, and so does the startup scan; a refusal there has nobody to be handed to.

pub fn refuse(&self, error: AxError) -> Delivered

Hands the refusal back, and says where it ended up.

Trait Implementations

impl Clone for Reply

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Reply

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

Says whether there is somebody to answer, and never what was said: the payload is an AxError on its way to one peer.