Struct EventHandlers 

pub struct EventHandlers { /* private fields */ }

Connection lifecycle event handlers.

All handlers are optional. The builder pattern makes it easy to register only the handlers you need. Handlers are Send + Sync so they work with the async tokio runtime.

These handlers are invoked across all SDK platforms (Rust, TypeScript, Dart) with the same semantics.

Implementations

impl EventHandlers

pub fn new() -> EventHandlers

Create a new empty EventHandlers (no callbacks registered).

pub fn on_connect(self, f: impl Fn() + Send + Sync + 'static) -> EventHandlers

Register a callback invoked when the shared connection becomes ready.

Example

use kalam_client::EventHandlers;

let handlers = EventHandlers::new().on_connect(|| println!("Connected!"));

pub fn on_disconnect( self, f: impl Fn(DisconnectReason) + Send + Sync + 'static, ) -> EventHandlers

Register a callback invoked when the WebSocket connection is closed.

The callback receives a DisconnectReason with details about why the connection was closed.

Example

use kalam_client::EventHandlers;

let handlers =
    EventHandlers::new().on_disconnect(|reason| println!("Disconnected: {}", reason));

pub fn on_error( self, f: impl Fn(ConnectionError) + Send + Sync + 'static, ) -> EventHandlers

Register a callback invoked when a connection error occurs.

The callback receives a ConnectionError indicating whether the error is recoverable (auto-reconnect may help) or fatal.

Example

use kalam_client::EventHandlers;

let handlers = EventHandlers::new()
    .on_error(|err| eprintln!("Error (recoverable={}): {}", err.recoverable, err));

pub fn on_receive( self, f: impl Fn(&str) + Send + Sync + 'static, ) -> EventHandlers

Register a callback invoked for every raw message received from the server.

This is a debug/tracing hook — it receives the raw JSON string of every inbound WebSocket message before parsing. Useful for logging or diagnostics. Not needed for normal operation.

Example

use kalam_client::EventHandlers;

let handlers = EventHandlers::new().on_receive(|msg| println!("[RECV] {}", msg));

pub fn on_send(self, f: impl Fn(&str) + Send + Sync + 'static) -> EventHandlers

Register a callback invoked for every raw message sent to the server.

This is a debug/tracing hook — it receives the raw JSON string of every outbound WebSocket message. Useful for logging or diagnostics.

Example

use kalam_client::EventHandlers;

let handlers = EventHandlers::new().on_send(|msg| println!("[SEND] {}", msg));

pub fn has_any(&self) -> bool

Returns true if any handler is registered.

Trait Implementations

impl Clone for EventHandlers

fn clone(&self) -> EventHandlers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventHandlers

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

Formats the value using the given formatter.

impl Default for EventHandlers

fn default() -> EventHandlers

Returns the “default value” for a type.