Struct stateright::actor::ordered_reliable_link::ActorWrapper

pub struct ActorWrapper<A: Actor> {
    pub resend_interval: Range<Duration>,
    pub wrapped_actor: A,
}

Wraps an actor with logic to:

1. Maintain message order.
2. Resend lost messages.
3. Avoid message redelivery.

Fields

resend_interval: Range<Duration>

wrapped_actor: A

Implementations

impl<A: Actor> ActorWrapper<A>

pub fn with_default_timeout(wrapped_actor: A) -> Self

Trait Implementations

impl<A: Actor> Actor for ActorWrapper<A> where
    A::Msg: Hash, 

type Msg = MsgWrapper<A::Msg>

The type of messages sent and received by the actor.

type State = StateWrapper<A::Msg, A::State>

The type of state maintained by the actor.

pub fn on_start(&self, id: Id, o: &mut Out<Self>) -> Self::State

Indicates the initial state and commands.

pub fn on_msg(
    &self,
    id: Id,
    state: &mut Cow<'_, Self::State>,
    src: Id,
    msg: Self::Msg,
    o: &mut Out<Self>
)

Indicates the next state and commands when a message is received. See Out::send.

pub fn on_timeout(
    &self,
    _id: Id,
    state: &mut Cow<'_, Self::State>,
    o: &mut Out<Self>
)

Indicates the next state and commands when a timeout is encountered. See Out::set_timer.

impl<A: Clone + Actor> Clone for ActorWrapper<A>

pub fn clone(&self) -> ActorWrapper<A>

Returns a copy of the value.

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

Performs copy-assignment from source.