Struct EventBus 

pub struct EventBus<I> { /* private fields */ }

One client’s live event bus. The client owns this value and passes writers down.

Implementations

impl<I> EventBus<I>

pub fn new() -> Self

pub fn subscribe( &self, filter: EventFilter<I>, queue_depth: Option<usize>, ) -> Subscription<I>

Registers before returning. None gives an internal worker an unbounded queue.

pub fn subscribe_app(&self, filter: EventFilter<I>) -> Option<Subscription<I>>

Register an app listener while the client is open.

pub fn close_app_subscriptions(&self)

End app listeners before worker shutdown begins.

pub fn close_internal_subscriptions(&self)

End legacy and other internal listeners after worker shutdown.

pub fn with_buffer<R, E>( &self, f: impl FnOnce(&EventBuffer<'_, I>) -> Result<R, E>, ) -> Result<R, E>

where I: Clone,

Runs one synchronous emitting write. Flush follows a successful commit only.

Trait Implementations

impl<I> Clone for EventBus<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I> Default for EventBus<I>

fn default() -> Self

Returns the “default value” for a type.

impl<I> EventWriter<I> for EventBus<I>

where I: Clone + MaybeSend + MaybeSync + 'static,

fn emit_with_context( &self, client: Option<ClientEvent>, internal: Option<I>, context: EventContext, )

fn emit(&self, client: Option<ClientEvent>, internal: Option<I>)