Struct HyperLiquidWs 

pub struct HyperLiquidWs { /* private fields */ }

HyperLiquid WebSocket client.

Provides real-time data streaming for HyperLiquid exchange.

Implementations

impl HyperLiquidWs

pub fn new(url: String) -> Self

Creates a new HyperLiquid WebSocket client.

Arguments

• url - WebSocket server URL

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

Connects to the WebSocket server.

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

Disconnects from the WebSocket server.

pub async fn state(&self) -> WsConnectionState

Returns the current connection state.

pub async fn is_connected(&self) -> bool

Checks if the WebSocket is connected.

pub async fn receive(&self) -> Option<Value>

Receives the next message from the WebSocket.

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

Subscribes to all mid prices.

pub async fn subscribe_l2_book(&self, symbol: &str) -> Result<()>

Subscribes to L2 order book updates.

Arguments

• symbol - Trading pair symbol (e.g., “BTC”)

pub async fn subscribe_trades(&self, symbol: &str) -> Result<()>

Subscribes to trade updates.

Arguments

• symbol - Trading pair symbol (e.g., “BTC”)

pub async fn subscribe_candle(&self, symbol: &str, interval: &str) -> Result<()>

Subscribes to candle updates.

Arguments

• symbol - Trading pair symbol (e.g., “BTC”)
• interval - Candle interval (e.g., “1m”, “1h”)

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

Subscribes to user events.

Arguments

• address - User’s Ethereum address

pub async fn subscribe_user_fills(&self, address: &str) -> Result<()>

Subscribes to user fills.

Arguments

• address - User’s Ethereum address

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

Subscribes to order updates.

Arguments

• address - User’s Ethereum address

impl HyperLiquidWs

pub fn client(&self) -> &Arc<WsClient>

Returns a reference to the WebSocket client.

pub fn subscriptions(&self) -> &Arc<RwLock<Vec<Subscription>>>

Returns a reference to the subscriptions.