Struct EventBroadcaster 

pub struct EventBroadcaster { /* private fields */ }

Event broadcaster for managing and broadcasting events

Implementations

impl EventBroadcaster

pub fn new() -> Self

Create a new event broadcaster

pub async fn subscribe(&self, filter: EventFilter) -> Receiver<Event>

Subscribe to events with a filter

pub async fn unsubscribe(&self, subscription_id: Uuid)

Unsubscribe from events

pub async fn broadcast(&self, event: Event) -> Result<()>

Broadcast an event

Errors

Returns an error if broadcasting fails

pub async fn broadcast_task_event( &self, event_type: EventType, _task_id: Uuid, data: Option<Value>, source: &str, ) -> Result<()>

Create and broadcast a task event

Errors

Returns an error if broadcasting fails

pub async fn broadcast_project_event( &self, event_type: EventType, _project_id: Uuid, data: Option<Value>, source: &str, ) -> Result<()>

Create and broadcast a project event

Errors

Returns an error if broadcasting fails

pub async fn broadcast_area_event( &self, event_type: EventType, _area_id: Uuid, data: Option<Value>, source: &str, ) -> Result<()>

Create and broadcast an area event

Errors

Returns an error if broadcasting fails

pub async fn broadcast_progress_event( &self, event_type: EventType, _operation_id: Uuid, data: Option<Value>, source: &str, ) -> Result<()>

Create and broadcast a progress event

Errors

Returns an error if broadcasting fails

pub async fn broadcast_progress_update( &self, update: ProgressUpdate, source: &str, ) -> Result<()>

Convert a progress update to an event

Errors

Returns an error if broadcasting fails

pub async fn subscription_count(&self) -> usize

Get the number of active subscriptions

pub fn subscribe_all(&self) -> Receiver<Event>

Get a receiver for all events (unfiltered)

Trait Implementations

impl Default for EventBroadcaster

fn default() -> Self

Returns the “default value” for a type.