Struct MessageRouter 

pub struct MessageRouter { /* private fields */ }

Message router

Handles reception, parsing, and dispatching of WebSocket messages. Core responsibilities:

• Managing WebSocket connections
• Receiving and routing messages
• Coordinating automatic reconnection
• Managing subscriptions

Implementations

impl MessageRouter

pub fn new( ws_url: String, subscription_manager: Arc<SubscriptionManager>, ) -> Self

Creates a new message router

Arguments

• ws_url - WebSocket connection URL
• subscription_manager - Subscription manager handle

Returns

Configured router instance

pub async fn start(&self) -> Result<()>

Starts the message router

Establishes the WebSocket connection and launches the message loop

Returns

Result of the startup sequence

pub async fn stop(&self) -> Result<()>

Stops the message router

Terminates the message loop and disconnects the WebSocket client

Returns

Result of the shutdown procedure

pub async fn restart(&self) -> Result<()>

Restarts the message router

Stops the current connection and restarts it, typically used during reconnect scenarios

Returns

Result of the restart sequence

pub fn is_connected(&self) -> bool

Returns the current connection state

pub async fn set_reconnect_config(&self, config: ReconnectConfig)

Applies a new reconnection configuration

Arguments

• config - Updated reconnection configuration

pub async fn get_reconnect_config(&self) -> ReconnectConfig

Retrieves the current reconnection configuration

pub async fn subscribe(&self, streams: Vec<String>) -> Result<()>

Subscribes to the provided streams

Sends a subscription request to Binance

Arguments

• streams - Collection of stream identifiers

pub async fn unsubscribe(&self, streams: Vec<String>) -> Result<()>

Unsubscribes from the provided streams

Sends an unsubscribe request to Binance

Arguments

• streams - Collection of stream identifiers

Trait Implementations

impl Drop for MessageRouter

fn drop(&mut self)

Executes the destructor for this type.