Struct CommandRunner 

pub struct CommandRunner<T: Handler> { /* private fields */ }

Central command dispatcher for the WebSocket session.

Reads Commands from an MPSC channel and dispatches them to the WebSocketClient. Manages connection lifecycle, reconnection, and error recovery.

Spawn via CommandRunner::run() — it blocks until shutdown is triggered.

Implementations

impl<T: Handler> CommandRunner<T>

pub fn new(rx: CommandRx, ws: Arc<WebSocketClient<T>>) -> Self

pub fn with_config( rx: CommandRx, ws: Arc<WebSocketClient<T>>, config: CommandRunnerConfig, ) -> Self

pub async fn run(self) -> Result<()>

pub fn shutdown_token(&self) -> CancellationToken

pub fn stats(&self) -> &ConnectionStats

pub fn state(&self) -> &ConnectionState

pub fn config(&self) -> &CommandRunnerConfig