Struct PropagateTermination 

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

Propagate a selected actor’s exact terminal report through this actor’s terminal boundary.

The target determines which authoritative observation is installed. A matching report is accepted once. The configured policy either discharges it locally or emits ReportTerminalOutcome unchanged and stops in the same Actions value. Publication-before-stop is interpreter policy; the actor-model nucleus does not define lifecycle observation or failure escalation.

A child selection requires a concrete protocol and an opaque creation ID:

struct Worker;
impl behavior::Protocol for Worker {
    type Addr = behavior::MailAddr;
    type Msg = behavior::Never;
}

let _ = behavior_actors::ChildTermination::<Worker, behavior::ChildHead>::new("not a creation ID");

Implementations

impl<B, Target> PropagateTermination<B, Target>

where B: Behavior, Target: TerminationTarget<BehaviorAddr<B>>,

pub const fn new( inner: B, target: Target, policy: TerminalPropagationPolicy<BehaviorAddr<B>>, ) -> Self

pub const fn state(&self) -> TerminalPropagationState

Trait Implementations

impl<B, Target, A, Ph, Sends, Br> Behavior for PropagateTermination<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: TerminationTarget<A>, Target::Report: Send, Target::Request: Send,

type Protocol = <B as Behavior>::Protocol

Stable public communication identity owned by this actor template.

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

type Sends = SendLayer<TerminalPropagationSends<InterpreterRequests<<Target as TerminationTarget<A>>::Request>, InterpreterRequests<ReportTerminalOutcome<A>>>, Sends>

type Ph = Ph

type Error = TerminationPropagationError<<B as Behavior>::Error, <Target as TerminationTarget<A>>::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 PropagateTermination<B, Target>

where B: Behavior + BehaviorBase, Target: TerminationTarget<BehaviorAddr<B>>,

type Base = <B as BehaviorBase>::Base

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

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

where B: Behavior + StashStatus, Target: TerminationTarget<BehaviorAddr<B>>,

fn stashed_messages(&self) -> usize