Struct ClientRunner 

pub struct ClientRunner<S: AppState> { /* private fields */ }

Implementation of the ClientRunner for managing WebSocket client connections and session lifecycle.

Implementations

impl<S: AppState> ClientRunner<S>

pub async fn run(&mut self)

Main client runner loop that manages WebSocket connections and message processing.

Examples found in repository

examples/echo_client.rs (line 312)

    pub async fn new(url: String) -> CoreResult<Self> {
        // Use a simple connector (implement your own if needed)
        let connector = DummyConnector::new(url);

        let mut builder = ClientBuilder::new(connector, ());
        builder =
            builder.with_lightweight_handler(|msg, state, _| Box::pin(print_handler(msg, state)));
        let (client, mut runner) = builder
            .with_module::<EchoModule>()
            .with_module::<StreamModule>()
            .with_module::<PeriodicSenderModule>()
            .build()
            .await?;

        // let echo_handle = client.get_handle::<EchoModule>().await.unwrap();
        // let stream_handle = client.get_handle::<StreamModule>().await.unwrap();

        // Start runner in background
        let _runner = tokio::spawn(async move { runner.run().await });

        Ok(Self { client, _runner })
    }