Struct EventSubscriptionObject 

pub struct EventSubscriptionObject {
    subscription_id: String,
    channel_name: String,
    task_id: u32,
    filters: Mutex<HashMap<usize, EventFilter>>,
}

EventSubscription implementation for KernelObject integration

Fields

subscription_id: String

channel_name: String

task_id: u32

filters: Mutex<HashMap<usize, EventFilter>>

Local registry of filters keyed by handler ID for this subscription

Implementations

impl EventSubscriptionObject

pub fn new(subscription_id: String, channel_name: String, task_id: u32) -> Self

pub fn subscription_id(&self) -> &str

pub fn channel_name(&self) -> &str

pub fn task_id(&self) -> u32

Trait Implementations

impl CloneOps for EventSubscriptionObject

fn custom_clone(&self) -> KernelObject

Perform a custom clone operation and return the cloned object

impl EventReceiver for EventSubscriptionObject

fn has_pending_events(&self) -> bool

Check if events are pending

impl EventSubscriber for EventSubscriptionObject

fn register_filter( &self, filter: EventFilter, handler_id: usize, ) -> Result<(), &'static str>

Register an event filter with a handler ID

fn unregister_filter(&self, handler_id: usize) -> Result<(), &'static str>

Unregister an event filter by handler ID

fn get_filters(&self) -> Vec<(usize, EventFilter)>

Get registered filters and their handler IDs