Skip to main content

PeriodicTimeTrigger

Struct PeriodicTimeTrigger 

Source
pub struct PeriodicTimeTrigger { /* private fields */ }
Expand description

Trigger criterion for regular simulation time intervals.

PeriodicTimeTrigger observes the simulation clock and emits repeatedly at a configured period and execution phase.

§Construction

PeriodicTimeTrigger::every(period)
PeriodicTimeTrigger::every_with_phase(period, phase)
PeriodicTimeTrigger::every(period).with_phase(phase) // Equivalent to `every_with_phase`
PeriodicTimeTrigger::every(period).start_with_delay(delay)
PeriodicTimeTrigger::every(period).start_at(start_time)

§Observation

The observation data passed to TriggerCriterion::emit_with is PeriodicTimeTriggerEvent. It contains the simulation time observed when the scheduled periodic plan runs, the configured period, and the phase used to schedule it:

pub struct PeriodicTimeTriggerEvent {
    pub time: f64,
    pub period: f64,
    pub phase: ExecutionPhase,
}

§Semantics

This trigger uses the same rescheduling behavior as periodic plans: when the scheduled callback runs, the next occurrence is scheduled at current_time + period if there are still plans in the queue. Unlike Context::add_periodic_plan_with_phase, the first occurrence is seeded explicitly so it can start at the current time, after a delay, or at an absolute simulation time.

By default, the first occurrence is scheduled at context.get_current_time() when the trigger is installed, and the execution phase is ExecutionPhase::Normal.

The period must be positive, finite, and not NaN. A delay must be non-negative, finite, and not NaN. An absolute start time must be finite and not NaN; the context validates at trigger installation that it is not in the past. Builder inputs are converted to f64 before these checks are applied.

Since time is monotonic, this criterion does not use Direction or TriggerMode. It emits whenever its periodic schedule executes. If several plans are scheduled for the same time, the selected ExecutionPhase controls phase ordering.

§Example

use ixa::{Context, ExecutionPhase, IxaEvent};
use ixa::triggers::{ContextTriggersExt, PeriodicTimeTrigger, TriggerCriterion};

#[derive(IxaEvent)]
struct ReportTimeReached {
    time: f64,
    period: f64,
    phase: ExecutionPhase,
}

let mut context = Context::new();

context.register_trigger(
    PeriodicTimeTrigger::every(7.0)
        .with_phase(ExecutionPhase::Last)
        .start_with_delay(7.0)
        .emit_with(|observation| ReportTimeReached {
            time: observation.time,
            period: observation.period,
            phase: observation.phase,
        }),
);

context.subscribe_to_event(|_context, _event: ReportTimeReached| {
    // collect periodic reports
});

Implementations§

Source§

impl PeriodicTimeTrigger

Source

pub fn every(period: impl Into<f64>) -> Self

Source

pub fn every_with_phase(period: impl Into<f64>, phase: ExecutionPhase) -> Self

Source

pub fn with_phase(self, phase: ExecutionPhase) -> Self

Source

pub fn start_with_delay(self, delay: impl Into<f64>) -> Self

Source

pub fn start_at(self, start_time: impl Into<f64>) -> Self

Trait Implementations§

Source§

impl TriggerCriterion for PeriodicTimeTrigger

Source§

type Observation = PeriodicTimeTriggerEvent

The data that represents what is observed when the criterion is met. This data is passed to the handler installed for this criterion.
Source§

fn install<F>(self, context: &mut Context, on_match: F)
where F: Fn(&mut Context, Self::Observation) + 'static,

Install the criterion’s monitoring logic in context.
Source§

fn emit_with<Ev, F>(self, make_event: F) -> Trigger<Self, Ev, F>
where Ev: IxaEvent, F: Fn(Self::Observation) -> Ev + 'static,

Bind this criterion to a constructor for a concrete user event.
Source§

fn emit_default<Ev>(self) -> Trigger<Self, Ev, impl Fn(Self::Observation) -> Ev>
where Ev: IxaEvent + Default,

Bind this criterion to a default-valued concrete user event.
Source§

fn emit_value<Ev>( self, event: Ev, ) -> Trigger<Self, Ev, impl Fn(Self::Observation) -> Ev>
where Ev: IxaEvent,

Bind this criterion to a constant concrete user event value.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
§

impl<T> ArchivePointee for T

§

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.
§

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

§

impl<T> LayoutRaw for T

§

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Returns the layout of the type.
§

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

§

unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool

Returns whether the given value has been niched. Read more
§

fn resolve_niched(out: Place<NichedOption<T, N1>>)

Writes data to out indicating that a T is niched.
§

impl<T> Pointee for T

§

type Metadata = ()

The metadata type for pointers and references to this type.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.