Struct GRPCStream 

pub struct GRPCStream { /* private fields */ }

gRPC stream client for Hyperliquid real-time data

Implementations

impl GRPCStream

pub fn new(endpoint: Option<String>) -> Self

Create a new gRPC stream client

pub fn configure(self, config: GRPCStreamConfig) -> Self

Configure stream options

pub fn on_error<F>(self, f: F) -> Self

where F: Fn(String) + Send + Sync + 'static,

Set error callback

pub fn on_close<F>(self, f: F) -> Self

where F: Fn() + Send + Sync + 'static,

Set close callback

pub fn on_connect<F>(self, f: F) -> Self

where F: Fn() + Send + Sync + 'static,

Set connect callback

pub fn on_reconnect<F>(self, f: F) -> Self

where F: Fn(u32) + Send + Sync + 'static,

Set reconnect callback

pub fn on_state_change<F>(self, f: F) -> Self

where F: Fn(ConnectionState) + Send + Sync + 'static,

Set state change callback

pub fn state(&self) -> ConnectionState

Get current connection state

pub fn connected(&self) -> bool

Check if connected

pub fn trades<F>(&mut self, coins: &[&str], callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to trades

pub fn orders<F>(&mut self, coins: &[&str], callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to orders

pub fn book_updates<F>( &mut self, coins: &[&str], callback: F, ) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to book updates

pub fn l2_book<F>(&mut self, coin: &str, callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to L2 order book

pub fn l2_book_with_options<F>( &mut self, coin: &str, n_levels: u32, n_sig_figs: Option<u32>, callback: F, ) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to L2 order book with options

pub fn l4_book<F>(&mut self, coin: &str, callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to L4 order book (individual orders with OIDs)

pub fn blocks<F>(&mut self, callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to blocks

pub fn twap<F>(&mut self, coins: &[&str], callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to TWAP updates

pub fn events<F>(&mut self, callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to events

pub fn writer_actions<F>(&mut self, callback: F) -> GRPCSubscription

where F: Fn(Value) + Send + Sync + 'static,

Subscribe to writer actions

pub fn unsubscribe(&mut self, subscription: &GRPCSubscription)

Unsubscribe

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

Start the stream in background (non-blocking)

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

Run the stream (blocking)

pub fn stop(&mut self)

Stop the stream

pub async fn ping(&self) -> bool

Ping the server