Struct TerminationMonitorWith 

pub struct TerminationMonitorWith<B: Behavior, Target: TerminationObservationTarget<B>> { /* private fields */ }

Observe one peer and apply its terminal report to complete behavior actions.

Unlike crate::Watch, the reaction returns the wrapped behavior’s full Actions. Cleanup communications, lifecycle publication, fresh creations, and termination therefore remain explicit behavior decisions. The selected target owns either late-bound logical-name observation or exact-incarnation observation; the runtime delivers the target’s declared typed report through the interpreter-request return path. Reactions are infallible because they receive mutable access to B: a fallible callback could change B and then reject the same report, violating transition atomicity. Ordinary delegated B transitions retain B::Error.

fn fallible(_: &mut App, _: behavior_actors::PeerStopped<behavior::MailAddr>) -> behavior::BehaviorActed<App> {
    Ok(behavior::Actions::cont())
}
let _ = behavior_actors::TerminationMonitor::new(App, behavior::MailAddr(1), fallible);

Implementations

impl<B: Behavior> TerminationMonitorWith<B, LogicalTerminationTarget<B>>

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

Construct an action-producing observation definition.

impl<B, P> TerminationMonitorWith<B, EstablishedTerminationTarget<B, P>>

where B: Behavior, P: Protocol<Addr = BehaviorAddr<B>>, BehaviorAddr<B>: EndpointAddress,

pub fn established( inner: B, request: ObserveEstablished<P>, react: EstablishedTerminationReaction<B, P>, ) -> Self

pub fn take_cancellation(&mut self) -> Option<CancelObservation<P>>

Transfer the target’s one cancellation request for an enclosing Actions lane.

impl<B: Behavior, Target: TerminationObservationTarget<B>> TerminationMonitorWith<B, Target>

pub fn observation(&self) -> TerminationObservation

Return whether this monitor awaits or has consumed its terminal report.

pub fn into_parts(self) -> (B, Target)

Recover the exact inner behavior and sole current observation target.

Trait Implementations

impl<B, Target, A, Ph, Sends, Br> Behavior for TerminationMonitorWith<B, Target>

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

type Protocol = <B as Behavior>::Protocol

Stable public communication identity owned by this actor template.

type Event = EventLayer<<Target as TerminationObservationTarget<B>>::Report, <B as Behavior>::Event>

type Sends = SendLayer<InterpreterRequests<<Target as TerminationObservationTarget<B>>::Request>, Sends>

type Ph = Ph

type Error = TerminationMonitorError<<B as Behavior>::Error, <Target as TerminationObservationTarget<B>>::Report>

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, Target> BehaviorBase for TerminationMonitorWith<B, Target>

where B: Behavior + BehaviorBase, Target: TerminationObservationTarget<B>,

type Base = <B as BehaviorBase>::Base

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

impl<B, Target> StashStatus for TerminationMonitorWith<B, Target>

where B: Behavior + StashStatus, Target: TerminationObservationTarget<B>,

fn stashed_messages(&self) -> usize