Struct Compose 

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

A behavior definition that may still be wrapped and initialized.

Definitions deliberately expose no mailbox fold:

use behavior::{Compose, Machine, MailAddr, Move, Never};

let mut definition: Compose<Machine<MailAddr, (), u8, (), Never>> =
    Compose::new(Machine::new((), (), |_, _, _| Ok(Move::Stay)));
definition.receive(MailAddr(0), 1);

Implementations

impl<B> Compose<B>

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

Begin a composition from the one concrete Behavior value being defined directly or by #[behavior].

impl<B: Behavior> Compose<B>

pub fn base(&self) -> &B::Base

where B: BehaviorBase,

pub fn definition(&self) -> &B

pub fn initialize(self) -> Result<Initialized<B>, B::Error>

Consume this definition, perform its one initialization fold, and return the active behavior together with the ordered initialization effects.

Errors

Returns the behavior’s controlled initialization failure. A failed definition is consumed and cannot be activated or retried.

pub fn stop_on_shutdown(self) -> Compose<StopOnShutdown<B>>

Stop normally when a typed shutdown request is folded.

pub fn finalize_on_shutdown( self, finalize: ShutdownReaction<B>, ) -> Compose<FinalizeOnShutdown<B>>

Apply one final pure fold, retain its sends and creations, and stop normally regardless of the fold’s become verdict.

pub fn watch( self, peer: B::Addr, on_stopped: LinkReaction<B>, ) -> Compose<Watch<B>>

Observe a peer and apply a pure reaction when it stops.

pub fn deadline( self, timer: TimerId, when: Option<Instant>, on_reached: DeadlineReaction<B>, ) -> Compose<Deadline<B>>

Apply a pure reaction when the given absolute time is reached.

pub fn receive_timeout( self, timer: TimerId, after: Duration, on_elapsed: ReceiveTimeoutReaction<B>, ) -> Compose<ReceiveTimeout<B>>

Notify the behavior once after an idle period containing no successful user communication.

Initialization and each successful continuing user fold emit a relative schedule. Service events never reset inactivity. A matching delivery is consumed before on_elapsed runs, and a continuing reaction remains unarmed until another successful continuing user communication.

pub fn stash(self, route: fn(&B::Msg) -> StashRoute) -> Compose<Stash<B>>

where B: Behavior<Ph = Never>,

Hold messages selected by route and replay them on Release.

pub fn children<C>( self, nonces: fn(usize) -> <B::Addr as Address>::Nonce, count: usize, build: fn(usize) -> Option<C>, ) -> Result<Compose<Supervisor<B, C>>, FleetError<<B::Addr as Address>::Nonce>>

where B: Behavior<Birth = Births<C>>, C: Behavior<Ph = Never, Addr = B::Addr>, <B::Addr as Address>::Nonce: From<u64>,

Create a supervised child topology with an explicit creator-local nonce assignment. Bombay does not infer routing identity from an integer position.

impl<B, C> Compose<Supervisor<B, C>>

where B: Behavior<Birth = Births<C>>, C: Behavior<Ph = Never, Addr = B::Addr>, <B::Addr as Address>::Nonce: From<u64>,

pub fn restart(self, strategy: Strategy) -> Self

pub fn when(self, policy: RestartPolicy) -> Self

pub fn within(self, maximum: u32, window: Duration) -> Self

pub fn on_supervision_failure( self, reaction: SupervisionFailureReaction<B>, ) -> Self

Apply a pure reaction when supervision can no longer preserve its child topology.