pub struct Deadline<B: Behavior> { /* private fields */ }Implementations§
Source§impl<B: Behavior> Deadline<B>
impl<B: Behavior> Deadline<B>
Sourcepub fn new(
inner: B,
id: TimerId,
at: Option<Instant>,
on_reached: DeadlineReaction<B>,
) -> Self
pub fn new( inner: B, id: TimerId, at: Option<Instant>, on_reached: DeadlineReaction<B>, ) -> Self
Wrap inner with one optional absolute deadline and pure reaction.
Initialization stages the schedule when at is present. Clock access
and timer delivery remain interpreter capabilities.
Nested timers remain independently addressable even when they reuse the
same (id, generation): each emitted schedule selects this wrapper’s
structural ingress destination.
The reaction is infallible because it receives mutable access to the
wrapped behavior; ordinary delegated transitions retain its error type.
Trait Implementations§
Source§impl<B, A, Ph, Sends, Br> Behavior for Deadline<B>
impl<B, A, Ph, Sends, Br> Behavior for Deadline<B>
Source§type Protocol = <B as Behavior>::Protocol
type Protocol = <B as Behavior>::Protocol
Stable public communication identity owned by this actor template. Read more
type Event = EventLayer<TimerElapsed, <B as Behavior>::Event>
type Sends = SendLayer<InterpreterRequests<ScheduleAt>, Sends>
type Ph = Ph
type Error = <B as Behavior>::Error
type Birth = Br
Source§fn init(
&mut self,
_: InitializationTurn,
) -> Result<Actions<BehaviorAddr<B>, <B as Behavior>::Ph, SendLayer<InterpreterRequests<ScheduleAt>, <B as Behavior>::Sends>, <B as Behavior>::Birth>, B::Error>
fn init( &mut self, _: InitializationTurn, ) -> Result<Actions<BehaviorAddr<B>, <B as Behavior>::Ph, SendLayer<InterpreterRequests<ScheduleAt>, <B as Behavior>::Sends>, <B as Behavior>::Birth>, B::Error>
Produce initialization actions before the first event is accepted. Read more
Source§fn transition(
&mut self,
_: ActiveTurn,
event: Self::Event,
) -> Result<Actions<BehaviorAddr<B>, <B as Behavior>::Ph, SendLayer<InterpreterRequests<ScheduleAt>, <B as Behavior>::Sends>, <B as Behavior>::Birth>, B::Error>
fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> Result<Actions<BehaviorAddr<B>, <B as Behavior>::Ph, SendLayer<InterpreterRequests<ScheduleAt>, <B as Behavior>::Sends>, <B as Behavior>::Birth>, B::Error>
Fold exactly one event into explicit actions and the next behavior. Read more
Source§fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Outputwhere
Self: Sized,
L: BehaviorLayer<Self>,
fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Outputwhere
Self: Sized,
L: BehaviorLayer<Self>,
Apply one statically dispatched construction layer. Read more
Source§impl<B: Behavior + BehaviorBase> BehaviorBase for Deadline<B>
impl<B: Behavior + BehaviorBase> BehaviorBase for Deadline<B>
Source§impl<B> StashStatus for Deadline<B>where
B: Behavior + StashStatus,
impl<B> StashStatus for Deadline<B>where
B: Behavior + StashStatus,
fn stashed_messages(&self) -> usize
Auto Trait Implementations§
impl<B> Freeze for Deadline<B>where
B: Freeze,
impl<B> RefUnwindSafe for Deadline<B>where
B: RefUnwindSafe,
impl<B> Send for Deadline<B>where
B: Send,
impl<B> Sync for Deadline<B>where
B: Sync,
impl<B> Unpin for Deadline<B>where
B: Unpin,
impl<B> UnsafeUnpin for Deadline<B>where
B: UnsafeUnpin,
impl<B> UnwindSafe for Deadline<B>where
B: UnwindSafe,
Blanket Implementations§
Source§impl<B> Activate for Bwhere
B: Behavior,
impl<B> Activate for Bwhere
B: Behavior,
Source§fn initialize(self) -> Result<Initialized<Self>, Self::Error>
fn initialize(self) -> Result<Initialized<Self>, Self::Error>
Consume this definition, perform its one initialization fold, and
return the active behavior together with the ordered initialization
effects. Read more
Source§impl<B> BeginShutdownPhases for B
impl<B> BeginShutdownPhases for B
type Output = ChildShutdownPhases<B, <<<B as Behavior>::Birth as BirthMode>::Child as ChildOccurrenceProduct<AvailableChildren>>::Product, NoPhases>
fn begin_shutdown_phases(self) -> <B as BeginShutdownPhases>::Output
Source§impl<Node> BirthNodeAppend<Never> for Nodewhere
Node: NonEmptyBirthNode,
impl<Node> BirthNodeAppend<Never> for Nodewhere
Node: NonEmptyBirthNode,
Source§type Output = Node
type Output = Node
Closed child algebra containing the complete prefix followed by the
complete appended tail.
Source§fn append_prefix(self) -> <Node as BirthNodeAppend<Never>>::Output
fn append_prefix(self) -> <Node as BirthNodeAppend<Never>>::Output
Inject one child from the existing prefix without changing its
structural occurrence.
Source§fn append_tail(tail: Never) -> <Node as BirthNodeAppend<Never>>::Output
fn append_tail(tail: Never) -> <Node as BirthNodeAppend<Never>>::Output
Inject one child from the appended tail after every prefix occurrence.
Source§fn append_creations<A>(
prefix: Creations<CreateChild<A, Self>>,
tail: Creations<CreateChild<A, Tail>>,
) -> Creations<CreateChild<A, Self::Output>>where
A: Address,
fn append_creations<A>(
prefix: Creations<CreateChild<A, Self>>,
tail: Creations<CreateChild<A, Tail>>,
) -> Creations<CreateChild<A, Self::Output>>where
A: Address,
Preserve and concatenate two ordered creation batches.
Source§impl<Child, Tail> BirthNodeAppend<Tail> for Childwhere
Child: Behavior,
Tail: NonEmptyBirthNode,
impl<Child, Tail> BirthNodeAppend<Tail> for Childwhere
Child: Behavior,
Tail: NonEmptyBirthNode,
Source§type Output = ChildChoice<Child, Tail>
type Output = ChildChoice<Child, Tail>
Closed child algebra containing the complete prefix followed by the
complete appended tail.
Source§fn append_prefix(self) -> <Child as BirthNodeAppend<Tail>>::Output
fn append_prefix(self) -> <Child as BirthNodeAppend<Tail>>::Output
Inject one child from the existing prefix without changing its
structural occurrence.
Source§fn append_tail(tail: Tail) -> <Child as BirthNodeAppend<Tail>>::Output
fn append_tail(tail: Tail) -> <Child as BirthNodeAppend<Tail>>::Output
Inject one child from the appended tail after every prefix occurrence.
Source§fn append_creations<A>(
prefix: Creations<CreateChild<A, Self>>,
tail: Creations<CreateChild<A, Tail>>,
) -> Creations<CreateChild<A, Self::Output>>where
A: Address,
fn append_creations<A>(
prefix: Creations<CreateChild<A, Self>>,
tail: Creations<CreateChild<A, Tail>>,
) -> Creations<CreateChild<A, Self::Output>>where
A: Address,
Preserve and concatenate two ordered creation batches.
Source§impl<B> BirthProtocols for B
impl<B> BirthProtocols for B
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<Node, Shape> ChildOccurrenceProduct<Shape> for Nodewhere
Node: ChildOccurrenceProductAt<ChildHead, Shape>,
Shape: ChildOccurrenceShape,
impl<Node, Shape> ChildOccurrenceProduct<Shape> for Nodewhere
Node: ChildOccurrenceProductAt<ChildHead, Shape>,
Shape: ChildOccurrenceShape,
Source§impl<A, Child, Host> DispatchBirth<A, Host> for Child
impl<A, Child, Host> DispatchBirth<A, Host> for Child
Source§fn dispatch_birth(
self,
id: CreationId,
route: <A as Address>::Nonce,
kind: CreationKind,
host: &mut Host,
) -> impl Future<Output = ItemSettlement<RoutedCreation<A, Child>, <Child as ChildCreationProduct<A, ChildHead>>::Result, CreationRejection, Never>> + Send
fn dispatch_birth( self, id: CreationId, route: <A as Address>::Nonce, kind: CreationKind, host: &mut Host, ) -> impl Future<Output = ItemSettlement<RoutedCreation<A, Child>, <Child as ChildCreationProduct<A, ChildHead>>::Result, CreationRejection, Never>> + Send
Select exactly one concrete child host while preserving creation data
in every non-accepted settlement.