Struct event_source::EventSource

pub struct EventSource<T: ForLifetime> { /* private fields */ }

Event source

Implementations

impl<T: ForLifetime> EventSource<T>

pub const fn new() -> Self

Create new [EventSource]

pub fn with_emitter(&self, emit_fn: impl FnOnce(EventEmitter<'_, T>))

pub fn on<F>(&self, listener: F) -> EventFnFuture<'_, F, T> where F: FnMut(T::Of<'_>) -> Option<()> + Sync,

Listen event until listener returns Option::Some

It can be called after woken if another event occurred before task continue.

pub async fn once<F, R>(&self, listener: F) -> Rwhere F: FnMut(T::Of<'_>) -> Option<R> + Sync, R: Sync,

Listen event until listener returns Option::Some

Unlike EventSource::on it will ignore every events once listener returns with Option::Some.

Trait Implementations

impl<T: ForLifetime> Debug for EventSource<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: ForLifetime> Send for EventSource<T>

impl<T: ForLifetime> Sync for EventSource<T>