pub struct EventLoop {
    fail_handle: Option<Arc<dyn FailHandle>>,
    poll_ctx: Arc<WaitContext<Descriptor>>,
    handlers: Arc<Mutex<BTreeMap<Descriptor, Weak<dyn EventHandler>>>>,
    stop_evt: Event,
}
Expand description

EventLoop is an event loop blocked on a set of fds. When a monitered events is triggered, event loop will invoke the mapped handler.

Fields§

§fail_handle: Option<Arc<dyn FailHandle>>§poll_ctx: Arc<WaitContext<Descriptor>>§handlers: Arc<Mutex<BTreeMap<Descriptor, Weak<dyn EventHandler>>>>§stop_evt: Event

Implementations§

source§

impl EventLoop

source

pub fn start( name: String, fail_handle: Option<Arc<dyn FailHandle>> ) -> Result<(EventLoop, JoinHandle<()>), Error>

Start an event loop. An optional fail handle could be passed to the event loop.

source

pub fn add_event( &self, descriptor: &dyn AsRawDescriptor, event_type: EventType, handler: Weak<dyn EventHandler> ) -> Result<(), Error>

Add a new event to event loop. The event handler will be invoked when event happens on descriptor.

If the same descriptor is added multiple times, the old handler will be replaced. EventLoop will not keep handler alive, if handler is dropped when event is triggered, the event will be removed.

source

pub fn remove_event_for_descriptor( &self, descriptor: &dyn AsRawDescriptor ) -> Result<(), Error>

Removes event for this descriptor. This function is safe to call even when the descriptor is not actively being polled because it’s been paused.

EventLoop does not guarantee all events for descriptor is handled.

source

pub fn pause_event_for_descriptor( &self, descriptor: &dyn AsRawDescriptor ) -> Result<(), Error>

Pauses polling on the given descriptor. It keeps a reference to the descriptor and its handler so it can be resumed by calling resume_event_for_descriptor().

source

pub fn resume_event_for_descriptor( &self, descriptor: &dyn AsRawDescriptor, event_type: EventType ) -> Result<(), Error>

Resumes polling on the given descriptor with the previously-provided handler. If descriptor was not paused beforehand, this function does nothing. If descriptor does not exist in the event loop, it returns an error. event_type does not need to match the previously registered event type.

source

pub fn stop(&self)

Stops this event loop asynchronously. Previous events might not be handled.

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
§

impl<T> Downcast for Twhere T: Any,

§

fn into_any(self: Box<T, Global>) -> Box<dyn Any, Global>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.
§

fn into_any_rc(self: Rc<T, Global>) -> Rc<dyn Any, Global>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
§

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
§

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

§

fn into_any_arc(self: Arc<T, Global>) -> Arc<dyn Any + Sync + Send, Global>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

§

fn vzip(self) -> V