Struct StopOnShutdown 

pub struct StopOnShutdown<B> { /* private fields */ }

Stop normally when the shutdown lane is received.

Implementations

impl<B> StopOnShutdown<B>

pub const fn new(inner: B) -> Self

Wrap inner so the first typed shutdown request stops it normally. This wrapper owns every shutdown request it adds. It therefore composes over any behavior without requiring the inner event algebra to already accept shutdown. When shutdown wrappers are nested, the outermost wrapper owns the request.

pub fn into_inner(self) -> B

Recover the original wrapped behavior after this wrapper is consumed.

Trait Implementations

impl<B, A, Ph, Sends, Br> Behavior for StopOnShutdown<B>

where A: Address, Sends: SendEffects + SendsFor<B::Event>, Br: BirthMode, B: Behavior<Ph = Ph, Sends = Sends, Birth = Br>, B::Protocol: Protocol<Addr = A>,

type Protocol = <B as Behavior>::Protocol

Stable public communication identity owned by this actor template.

type Event = EventLayer<ShutdownRequested, <B as Behavior>::Event>

type Sends = SendLayer<NoSends, Sends>

type Ph = Ph

type Error = <B as Behavior>::Error

type Birth = Br

fn init( &mut self, _: InitializationTurn, ) -> Result<Actions<A, Ph, Self::Sends, Br>, B::Error>

Produce initialization actions before the first event is accepted.

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> Result<Actions<A, Ph, Self::Sends, Br>, B::Error>

Fold exactly one event into explicit actions and the next behavior.

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output

where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer.

impl<B: Behavior + BehaviorBase> BehaviorBase for StopOnShutdown<B>

type Base = <B as BehaviorBase>::Base

fn base(&self) -> &Self::Base

impl<B: StashStatus> StashStatus for StopOnShutdown<B>

fn stashed_messages(&self) -> usize