Struct EventLoop 

pub struct EventLoop { /* private fields */ }

Generic event loop with type-safe callbacks

Implementations

impl EventLoop

pub fn new() -> (Self, UnboundedReceiver<(String, Value)>)

Create a new event loop

pub async fn on_event<T, F, Fut>(&self, event_type: &str, callback: F)

where T: DeserializeOwned + Send + Sync + 'static, F: Fn(ServerEvent<T>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Register a typed callback for a specific event type

Example

event_loop.on_event(EVENT_MESSAGE_RECEIVED, |event: ServerEvent<MessageReceivedData>| {
    Box::pin(async move {
        println!("New message: {:?}", event.data.content);
    })
}).await;

pub async fn on<T, F, Fut>(&self, event_type: &'static str, handler: F)

where T: DeserializeOwned + Send + Sync + 'static, F: Fn(ServerEvent<T>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Register a handler function directly (simplified API)

This is a convenience wrapper around on_event that allows direct registration of async handler functions without wrapping them in closures.

Example

// 定义 handler 函数
async fn on_message_received(event: ServerEvent<MessageReceivedData>) {
    println!("New message: {:?}", event.data.content);
}

// 直接注册，无需包装闭包
event_loop.on(EVENT_MESSAGE_RECEIVED, on_message_received).await;

pub async fn off_event(&self, event_type: &str)

Remove all callbacks for a specific event type

pub async fn clear_callbacks(&self)

Clear all callbacks

pub async fn process_event(&self, event_type: &str, payload: Value)

Process a single event

pub async fn start(&self, event_rx: UnboundedReceiver<(String, Value)>)

Start the event loop

pub async fn is_running(&self) -> bool

Check if the event loop is running

pub fn event_sender(&self) -> UnboundedSender<(String, Value)>

Get event sender

Trait Implementations

impl Clone for EventLoop

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventLoop

fn default() -> Self

Returns the “default value” for a type.