Struct EventChannelObject 

pub struct EventChannelObject {
    name: String,
    subscriptions: Mutex<HashMap<String, Arc<EventSubscriptionObject>>>,
    manager_ref: &'static EventManager,
}

EventChannel implementation for KernelObject integration

Fields

name: String

subscriptions: Mutex<HashMap<String, Arc<EventSubscriptionObject>>>

Channel manages its own subscriptions as EventSubscriptionObjects

manager_ref: &'static EventManager

Implementations

impl EventChannelObject

pub fn new(name: String) -> Self

pub fn name(&self) -> &str

pub fn create_subscription( &self, task_id: u32, ) -> Result<Arc<EventSubscriptionObject>, EventError>

Create a new subscription for this channel

pub fn remove_subscription( &self, subscription_id: &str, ) -> Result<(), EventError>

Remove a subscription from this channel

pub fn get_subscriptions(&self) -> Vec<Arc<EventSubscriptionObject>>

Get all subscriptions for this channel

pub fn get_subscribers(&self) -> Vec<u32>

Get list of current subscriber task IDs

pub fn broadcast_to_subscribers(&self, event: Event) -> Result<(), EventError>

Send event to all subscribers of this channel

pub fn subscribe( &self, task_id: u32, ) -> Result<Arc<EventSubscriptionObject>, EventError>

Subscribe a task to this channel (legacy method for backward compatibility)

pub fn unsubscribe(&self, task_id: u32) -> Result<(), EventError>

Unsubscribe a task from this channel (legacy method for backward compatibility)

pub fn get_subscription_by_id( &self, subscription_id: &str, ) -> Option<Arc<EventSubscriptionObject>>

Get a subscription by its ID

Trait Implementations

impl CloneOps for EventChannelObject

fn custom_clone(&self) -> KernelObject

Perform a custom clone operation and return the cloned object

impl EventReceiver for EventChannelObject

fn has_pending_events(&self) -> bool

Check if events are pending

impl EventSender for EventChannelObject

fn send_event(&self, event: Event) -> Result<(), &'static str>

Send an event