Struct Client 

pub struct Client { /* private fields */ }

High-level client with automatic message handling

This is a simplified wrapper around aerox_client::HighLevelClient that provides a cleaner API for common client operations.

Example

use aerox::Client;

#[tokio::main]
async fn main() -> aerox::Result<()> {
    let mut client = Client::connect("127.0.0.1:8080").await?;

    // Register message handler
    client.on_message(1001, |id, msg: MyMessage| async move {
        println!("Received: {:?}", msg);
        Ok(())
    }).await?;

    // Send message
    client.send(1001, &my_message).await?;

    Ok(())
}

Implementations

impl Client

pub async fn connect(addr: impl Into<String>) -> Result<Self>

Connect to a server

Arguments

• addr - Server address (e.g., “127.0.0.1:8080”)

Example

let client = Client::connect("127.0.0.1:8080").await?;

pub async fn on_message<M, F>(&mut self, msg_id: u16, f: F) -> Result<()>

where M: Message + Default + Send + 'static, F: Fn(u16, M) -> Pin<Box<dyn Future<Output = ClientResult<()>> + Send>> + Send + Sync + 'static,

Register a message handler

Arguments

• msg_id - Message ID to handle
• f - Async handler function

Example

client.on_message(1001, |id, msg: MyMessage| async move {
    println!("Received message {}: {:?}", id, msg);
    Ok(())
}).await?;

pub async fn send<M: Message>(&mut self, msg_id: u16, msg: &M) -> Result<()>

Send a message

Arguments

• msg_id - Message ID
• msg - Message to send (must implement prost::Message)

Example

client.send(1001, &my_message).await?;

pub async fn is_connected(&self) -> bool

Check if connected to the server

Example

if client.is_connected().await {
    println!("Still connected");
}

pub fn inner(&self) -> &InnerClient

Get the inner client for advanced use cases

pub fn inner_mut(&mut self) -> &mut InnerClient

Get a mutable reference to the inner client for advanced use cases

pub fn into_inner(self) -> InnerClient

Consume and return the inner client