Struct Watch 

pub struct Watch<B: Behavior> { /* private fields */ }

Observe a logical peer name across any number of later incarnations.

A logical name can denote another incarnation after a stop, so every matching report is accepted and the watch remains observing. This recurrence law is distinct from crate::TerminationMonitor, which consumes one correlated terminal relationship. Initialization emits one typed ObservePeer request after preserving the inner initialization effects.

Implementations

impl<B: Behavior> Watch<B>

pub const fn new( inner: B, peer: BehaviorAddr<B>, on_stopped: LinkReaction<B>, ) -> Self

Wrap inner with recurring observation of one logical peer name.

Trait Implementations

impl<B, A, Ph, Sends, Br> Behavior for Watch<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<PeerStopped<<<B as Behavior>::Event as UserEvent>::Addr>, <B as Behavior>::Event>

type Sends = SendLayer<InterpreterRequests<ObservePeer<A>>, Sends>

type Ph = Ph

type Error = TerminationMonitorError<<B as Behavior>::Error, PeerStopped<A>>

type Birth = Br

fn init(&mut self, _: InitializationTurn) -> BehaviorActed<Self>

Produce initialization actions before the first event is accepted.

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

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> BehaviorBase for Watch<B>

where B: Behavior + BehaviorBase,

type Base = <B as BehaviorBase>::Base

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

impl<B> StashStatus for Watch<B>

where B: Behavior + StashStatus,

fn stashed_messages(&self) -> usize