Struct appliance::Appliance

pub struct Appliance<M> { /* fields omitted */ }

A stateful entity that only allows to interact with via handling messages.

Implementations

impl<'a, M: Send + 'static> Appliance<M>

pub fn new_bounded<S: Send + 'a>(
    executor: &Executor<'a>,
    state: S,
    handler: impl Fn(&mut S, M) + Send + 'a,
    size: usize
) -> Self

Creates a new appliance with a bounded message buffer, a state, and a handler.

pub fn new_unbounded<S: Send + 'a>(
    executor: &Executor<'a>,
    state: S,
    handler: impl Fn(&mut S, M) + Send + 'a
) -> Self

Creates a new appliance with an unbounded message buffer, a state, and a handler.

pub fn send(&self, message: M) -> Result<(), Error>

Sends a message to the current appliance without waiting for the message to be handled.

pub fn send_and_wait(&self, message: M) -> Result<(), Error>

Sends a message to the current appliance and waits indefinitely for the message to be handled. This blocking method is a fit for callers who must be assured that the message has been handled. It is supposed to be used less often then send as it may suffer a performance hit due to synchronization with the handling loop.

Trait Implementations

impl<M: Debug> Debug for Appliance<M>

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

Formats the value using the given formatter.