Struct BinanceSpotMessageHandler

pub struct BinanceSpotMessageHandler { /* private fields */ }

Message handler for Binance Spot WebSocket connections

Implementations

impl BinanceSpotMessageHandler

pub const fn new_trade_handler( clock: Clock, stats: Arc<RwLock<ConnectionStats>>, trade_tx: Sender<TradeMessage>, is_combined: bool, subscription_message: Option<String>, ) -> Self

Create a new message handler for trade messages

pub const fn new_orderbook_handler( clock: Clock, stats: Arc<RwLock<ConnectionStats>>, orderbook_tx: Sender<OrderbookMessage>, is_combined: bool, subscription_message: Option<String>, ) -> Self

Create a new message handler for orderbook messages

Trait Implementations

impl MessageHandler for BinanceSpotMessageHandler

fn on_connected<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle connection established

fn on_message<'life0, 'async_trait>( &'life0 mut self, message: Message, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a received message

fn on_disconnected<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle connection closed

fn on_error<'life0, 'async_trait>( &'life0 mut self, error: WebSocketError, ) -> Pin<Box<dyn Future<Output = Result<(), WebSocketError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handle errors

fn set_sender(&mut self, _sender: UnboundedSender<Message>)

Set the sender for outgoing messages (optional, default implementation does nothing)

fn send_message(&self, _message: Message) -> Result<(), WebSocketError>

Send a message through the WebSocket (optional, default implementation returns error)