Struct BitmexWebSocket 

pub struct BitmexWebSocket { /* private fields */ }

BitMEX WebSocket connector backed by UniversalWsTransport<BitmexProtocol>.

Implementations

impl BitmexWebSocket

pub fn new(testnet: bool) -> Self

Create a new connector (does NOT connect — call connect() first).

testnet — connects to wss://ws.testnet.bitmex.com/realtime when true.

Trait Implementations

impl WebSocketConnector for BitmexWebSocket

fn connect<'life0, 'async_trait>( &'life0 self, _account_type: AccountType, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

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

Подключиться к WebSocket

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

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

Отключиться от WebSocket

fn connection_status(&self) -> ConnectionStatus

Получить текущий статус подключения

fn subscribe<'life0, 'async_trait>( &'life0 self, request: SubscriptionRequest, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

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

Подписаться на поток данных

fn unsubscribe<'life0, 'async_trait>( &'life0 self, request: SubscriptionRequest, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

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

Отписаться от потока данных

fn event_stream( &self, ) -> Pin<Box<dyn Stream<Item = WebSocketResult<StreamEvent>> + Send>>

Получить поток событий

fn active_subscriptions(&self) -> Vec<SubscriptionRequest>

Получить список активных подписок

fn ping_rtt_handle(&self) -> Option<Arc<TokioMutex<u64>>>

Get a shared handle to the WS ping round-trip time (ms).

fn orderbook_capabilities( &self, _account_type: AccountType, ) -> OrderbookCapabilities

Returns the exchange’s L2/orderbook capabilities for the given account type.

fn has_subscription(&self, request: &SubscriptionRequest) -> bool

Проверить наличие подписки