Struct TimerRegistry 

pub struct TimerRegistry { /* private fields */ }

Handlers keyed by the id the node returned from timer_create.

Implementations

impl TimerRegistry

pub fn new() -> Arc<Self>

pub fn register( &self, id: TimerId, exec: Exec, ack: AckMode, run: Arc<dyn Fn(TimerFire) -> Pin<Box<dyn Future<Output = Result<TimerAck, String>> + Send>> + Send + Sync>, )

pub fn is_detached(&self, id: &TimerId) -> bool

pub fn start_detached( self: &Arc<Self>, fire: TimerFire, correlation_id: u64, result_tx: Sender<InvocationResultMessage>, )

Start a Task, Blocking, or Dedicated handler. The result is sent later.

pub async fn run_serial( &self, correlation_id: u64, fire: &TimerFire, result_tx: Sender<InvocationResultMessage>, )

Await a Serial handler. Receipt is sent before the handler runs. The caller still waits, so a serial handler keeps the module loop off events until it returns.