Struct WsManager 

pub struct WsManager { /* private fields */ }

Manages a single WebSocket feed: connect, receive, reconnect.

In production, WsManager wraps tokio-tungstenite. In tests, it operates in simulation mode with injected messages.

Implementations

impl WsManager

pub fn new(config: ConnectionConfig) -> Self

pub fn connect_simulated(&mut self)

Simulate a connection (for testing without live WebSocket). Increments connect_attempts to reflect the initial connection slot.

pub fn disconnect_simulated(&mut self)

Simulate a disconnection.

pub fn is_connected(&self) -> bool

pub fn connect_attempts(&self) -> u32

pub fn config(&self) -> &ConnectionConfig

pub fn can_reconnect(&self) -> bool

Check whether the next reconnect attempt is allowed.

pub fn next_reconnect_backoff(&mut self) -> Result<Duration, StreamError>

Consume a reconnect slot and return the backoff duration to wait.