Struct ClientHandle 

pub struct ClientHandle { /* private fields */ }

Handle for sending messages and receiving events.

Implementations

impl ClientHandle

pub fn send(&mut self, message: Vec<u8>) -> Result<(), ClientError>

Sends an SBE message to the server (non-blocking).

Errors

Returns error if the channel is disconnected.

pub fn disconnect(&mut self)

Disconnects from the server.

pub fn poll(&mut self) -> Option<ClientEvent>

Polls for events (non-blocking).

pub fn poll_spin(&mut self) -> ClientEvent

Busy-poll for next event (for hot path).

pub fn drain(&mut self) -> impl Iterator<Item = ClientEvent> + '_

Drains all available events.

pub async fn wait_event(&mut self) -> Option<ClientEvent>

Asynchronously waits for the next event.

Returns Some(event) when an event is available, or keeps waiting. Returns None only if the sender (client) has been dropped.

pub fn event_notifier(&self) -> Arc<Notify>

Returns a clone of the event notification handle.

Use this to await event availability when holding the handle behind a Mutex — await the notifier outside the lock, then lock and drain with [poll].