Struct dbs_utils::epoll_manager::EventManager

pub struct EventManager<T> { /* private fields */ }

Allows event subscribers to be registered, connected to the event loop, and later removed.

Implementations

impl<S> EventManager<S> where
    S: MutEventSubscriber, 

pub fn new() -> Result<EventManager<S>, Error>

Create a new EventManger object.

pub fn new_with_capacity(
    ready_events_capacity: usize
) -> Result<EventManager<S>, Error>

Creates a new EventManger object with specified event capacity.

Arguments

• ready_events_capacity: maximum number of ready events to be processed a single run. The maximum value of this parameter is EventManager::MAX_READY_EVENTS_CAPACITY.

pub fn run(&mut self) -> Result<usize, Error>

Run the event loop blocking until events are triggered or an error is returned. Calls subscriber.process() for each event.

On success, it returns number of dispatched events or 0 when interrupted by a signal.

pub fn run_with_timeout(&mut self, milliseconds: i32) -> Result<usize, Error>

Wait for events for a maximum timeout of miliseconds or until an error is returned. Calls subscriber.process() for each event.

On success, it returns number of dispatched events or 0 when interrupted by a signal.

impl<S> EventManager<S> where
    S: MutEventSubscriber, 

pub fn remote_endpoint(&self) -> RemoteEndpoint<S>

Return a RemoteEndpoint object, that allows interacting with the EventManager from a different thread. Using RemoteEndpoint::call_blocking on the same thread the event loop runs on leads to a deadlock.

Trait Implementations

impl<T> SubscriberOps for EventManager<T> where
    T: MutEventSubscriber, 

fn add_subscriber(&mut self, subscriber: T) -> SubscriberId

Register a subscriber with the event event_manager and returns the associated ID.

fn remove_subscriber(&mut self, subscriber_id: SubscriberId) -> Result<T, Error>

Unregisters and returns the subscriber associated with the provided ID.

fn subscriber_mut(
    &mut self,
    subscriber_id: SubscriberId
) -> Result<&mut T, Error>

Return a mutable reference to the subscriber associated with the provided id.

fn event_ops(
    &mut self,
    subscriber_id: SubscriberId
) -> Result<EventOps<'_>, Error>

Returns a EventOps object for the subscriber associated with the provided ID.

type Subscriber = T

Subscriber type for which the operations apply.