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

Create a new manager from a validated ConnectionConfig.

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

Whether the managed connection is currently in the connected state.

pub fn connect_attempts(&self) -> u32

Total connection attempts made so far (including the initial connect).

pub fn config(&self) -> &ConnectionConfig

The configuration this manager was created with.

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.