Struct Dispatcher 

pub struct Dispatcher<S: EventSource> { /* private fields */ }

Implementations

impl<S: EventSource> Dispatcher<S>

pub fn new(source: S) -> Self

Creates a dispatcher with default configuration.

pub fn with_config(source: S, config: ClientConfig) -> Self

Creates a dispatcher with a custom configuration.

pub fn source(&self) -> &S

Returns the underlying event source.

pub fn source_mut(&mut self) -> &mut S

Returns a mutable reference to the event source.

pub fn add_handler<F>(&mut self, event: Event, handler: F)

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for a specific event.

pub fn add_handler_any<F>(&mut self, handler: F)

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler which receives all events.

pub fn on_event<F>(self, event: Event, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler and returns the dispatcher for chaining.

pub fn on_any<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for all events and returns the dispatcher for chaining.

pub fn on_user_joined<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for user join events.

pub fn on_user_left<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for user left events.

pub fn on_text_message<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for text messages.

pub fn on_connect_success<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for connection success events.

pub fn on_connection_lost<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for connection lost events.

pub fn on_connect_failed<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for connection failure events.

pub fn on_command_error<F>(self, handler: F) -> Self

where F: for<'a> FnMut(EventContext<'a>) -> DispatchFlow + Send + 'static,

Adds a handler for command error events.

pub fn stop(&mut self)

Requests the dispatcher loop to stop.

pub fn run(&mut self) -> DispatchFlow

Runs the dispatcher loop with the configured timeout.

pub fn run_with_timeout(&mut self, timeout_ms: i32) -> DispatchFlow

Runs the dispatcher loop with an explicit timeout.

pub fn step(&mut self, timeout_ms: i32) -> DispatchFlow

Performs one poll/dispatch step.