Struct HyperliquidWebSocketClient 

pub struct HyperliquidWebSocketClient { /* private fields */ }

High-level Hyperliquid WebSocket client that provides standardized domain methods.

This is the outer client that wraps the inner client and provides Nautilus-specific functionality for WebSocket operations using standard domain methods.

Implementations

impl HyperliquidWebSocketClient

pub async fn connect(url: &str) -> Result<Self>

Creates a new Hyperliquid WebSocket client.

pub async fn subscribe_order_updates(&mut self, user: &str) -> Result<()>

Subscribe to order updates for a specific user address.

pub async fn subscribe_user_events(&mut self, user: &str) -> Result<()>

Subscribe to user events (fills, funding, liquidations) for a specific user address.

pub async fn subscribe_all_user_channels(&mut self, user: &str) -> Result<()>

Subscribe to all user channels (order updates + user events) for convenience.

pub async fn next_event(&mut self) -> Option<HyperliquidWsMessage>

Get the next event from the WebSocket stream. Returns None when the connection is closed or the receiver is exhausted.

pub fn is_active(&self) -> bool

Returns true if the WebSocket connection is active.

pub fn is_reconnecting(&self) -> bool

Returns true if the WebSocket is reconnecting.

pub fn is_disconnecting(&self) -> bool

Returns true if the WebSocket is disconnecting.

pub fn is_closed(&self) -> bool

Returns true if the WebSocket is closed.

pub async fn disconnect(&mut self) -> Result<()>

Disconnect the WebSocket client.

pub async fn send_raw(&mut self, request: &HyperliquidWsRequest) -> Result<()>

Escape hatch: send raw requests for tests/power users.

pub async fn info_l2_book( &mut self, coin: &str, timeout: Duration, ) -> HyperliquidResult<HyperliquidL2Book>

High-level: call info l2Book (WS post)

pub async fn post_info_raw( &mut self, payload: Value, timeout: Duration, ) -> HyperliquidResult<PostResponsePayload>

High-level: fire arbitrary info (WS post) returning raw payload.

pub async fn post_action_raw( &mut self, action: ActionPayload, timeout: Duration, ) -> HyperliquidResult<PostResponsePayload>

High-level: fire action (already signed ActionPayload)

Trait Implementations

impl Debug for HyperliquidWebSocketClient

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

Formats the value using the given formatter.