Struct EventBus 

pub struct EventBus { /* private fields */ }

The event bus for managing events within a task context

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn with_handlers(handlers: Vec<Arc<dyn EventHandler>>) -> Self

Create a new event bus with handlers

pub async fn run<F, Fut, T>(&self, f: F) -> T

where F: FnOnce() -> Fut, Fut: Future<Output = T>,

Run a function with this event bus as the task-local context

pub async fn register_handler(handler: Arc<dyn EventHandler>) -> Result<()>

Register an event handler to the current task-local event bus

pub async fn emit( event: AlienEvent, parent_id: Option<String>, state: EventState, ) -> Result<EventHandle>

Emit a new event using the current task-local event bus

pub async fn update(id: &str, event: AlienEvent) -> Result<()>

Update an existing event using the current task-local event bus

pub async fn update_state(id: &str, new_state: EventState) -> Result<()>

Update the state of an event using the current task-local event bus

pub async fn with_parent<F, Fut, T>(parent_id: Option<String>, f: F) -> T

where F: FnOnce(&EventHandle) -> Fut, Fut: Future<Output = T>,

Run a function with a parent event context

pub fn current() -> Option<Self>

Get the current event bus from task-local storage if available

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.