Struct CallbackExecutor 

pub struct CallbackExecutor { /* private fields */ }

A simple executor that queues callbacks for later processing

The executor provides a thread-safe way to enqueue callbacks from subscriber threads and process them in the node’s spin loop.

Implementations

impl CallbackExecutor

pub fn new() -> Self

Creates a new callback executor

pub fn enqueue(&self, callback: Callback)

Enqueues a callback for later processing

This method is thread-safe and can be called from subscriber callbacks.

pub fn process_pending(&self) -> usize

Processes all pending callbacks

Returns the number of callbacks that were processed.

pub fn pending_count(&self) -> usize

Returns the number of pending callbacks

pub fn notified(&self) -> Notified<'_>

Returns a future that resolves when a callback is enqueued or shutdown is signaled. Must be called (to register interest) before draining the queue.

pub fn shutdown(&self)

Signals the executor to shutdown

After shutdown, no new callbacks will be accepted.

pub fn is_shutdown(&self) -> bool

Returns true if the executor has been shutdown

Trait Implementations

impl Clone for CallbackExecutor

fn clone(&self) -> CallbackExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for CallbackExecutor

fn default() -> Self

Returns the “default value” for a type.