Struct WebSocketStreamer 

pub struct WebSocketStreamer;

WebSocket streaming utilities

Implementations

impl WebSocketStreamer

pub fn create_event_notifier() -> (WebSocketEventSender, WebSocketEventReceiver)

Create a connection event notifier

pub fn create_message_channel() -> (WebSocketMessageSender, WebSocketMessageReceiver)

Create a message channel for real-time communication

pub fn create_state_watcher( initial_state: WebSocketState, ) -> (Sender<WebSocketState>, Receiver<WebSocketState>)

Create a connection state watcher

pub fn validate_config(config: &WebSocketConfig) -> Result<(), String>

Validate WebSocket configuration

Errors

Returns an error if any configuration parameters are invalid (e.g., zero timeouts, invalid limits).

pub fn create_heartbeat_timer(interval: Duration) -> UnboundedReceiver<Instant>

Create a heartbeat timer

pub fn calculate_reconnect_delay( attempt: u32, base_delay_ms: u64, max_delay_ms: u64, ) -> Duration

Calculate reconnection delay with exponential backoff

pub fn process_message_queue( connection: &WebSocketConnection, max_messages: usize, ) -> Vec<WebSocketMessage>

Process message queue for a connection

pub fn connection_statistics( connection: &WebSocketConnection, ) -> WebSocketConnectionStats

Create connection statistics

Trait Implementations

impl Debug for WebSocketStreamer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.