Struct StreamClient 

pub struct StreamClient { /* private fields */ }

Low-level stream client

This is a re-export of aerox_client::StreamClient for users who need fine-grained control over message handling.

Example

use aerox::StreamClient;

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

    // Manual send/receive loop
    client.send_message(1001, &msg).await?;
    let (msg_id, response) = client.recv_message::<Response>().await?;

    client.close().await?;
    Ok(())
}

Stream-based client

Provides manual control over message operations. Users explicitly call send/receive methods.

Implementations

impl StreamClient

pub async fn connect(addr: SocketAddr) -> Result<StreamClient, ClientError>

Connect to server

pub async fn connect_with_config( config: ClientConfig, ) -> Result<StreamClient, ClientError>

Connect with custom configuration

pub async fn send_frame(&mut self, frame: Frame) -> Result<(), ClientError>

Send raw frame

pub async fn send_message<M>( &mut self, msg_id: u16, message: &M, ) -> Result<(), ClientError>

where M: Message,

Send protobuf message

pub async fn recv_frame(&mut self) -> Result<Frame, ClientError>

Receive next frame (blocking)

pub async fn recv_message<M>(&mut self) -> Result<(u16, M), ClientError>

where M: Message + Default,

Receive and decode protobuf message

pub async fn state(&self) -> ClientState

Get connection state

pub async fn is_connected(&self) -> bool

Check if connected

pub fn server_addr(&self) -> SocketAddr

Get server address

pub async fn close(self) -> Result<(), ClientError>

Close connection

pub fn connection(&mut self) -> &mut ClientConnection

Get connection reference (for advanced usage)