Struct StreamApi 

pub struct StreamApi { /* private fields */ }

Stream API client for real-time data subscriptions

Implementations

impl StreamApi

pub fn new(url: &str, access_token: &str) -> Self

Create a new StreamApi instance

pub fn is_connected(&self) -> bool

Check if connected

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

Connect to the WebSocket server

pub async fn disconnect(&self)

Disconnect from the WebSocket server

pub async fn subscribe<F>( &self, channel: &str, callback: F, filter: Option<&str>, method_name: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to a channel with a raw callback

pub async fn subscribe_token_candles<F>( &self, chain: &str, token_address: &str, resolution: Resolution, callback: F, filter: Option<&str>, price_type: Option<PriceType>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token candle data price_type: PriceType::Usd (default) or PriceType::Native

pub async fn subscribe_pool_candles<F>( &self, chain: &str, pool_address: &str, resolution: Resolution, callback: F, filter: Option<&str>, price_type: Option<PriceType>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to pool candle data price_type: PriceType::Usd (default) or PriceType::Native

pub async fn subscribe_pair_candles<F>( &self, chain: &str, pair_address: &str, resolution: Resolution, callback: F, filter: Option<&str>, price_type: Option<PriceType>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to pair candle data pair_address format: {tokenA}-{tokenB} price_type: PriceType::Usd (default) or PriceType::Native

pub async fn subscribe_token_stats<F>( &self, chain: &str, token_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token statistics

pub async fn subscribe_new_token<F>( &self, chain: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to new tokens

pub async fn subscribe_token_trade<F>( &self, chain: &str, token_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token trades

pub async fn subscribe_wallet_balance<F>( &self, chain: &str, wallet_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to wallet balance

pub async fn subscribe_token_holders<F>( &self, chain: &str, token_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token holders

pub async fn subscribe_token_supply<F>( &self, chain: &str, token_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token supply

pub async fn subscribe_dex_pool_balance<F>( &self, chain: &str, pool_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to DEX pool balance

pub async fn subscribe_token_max_liquidity<F>( &self, chain: &str, token_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token max liquidity

pub async fn subscribe_token_total_liquidity<F>( &self, chain: &str, token_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to token total liquidity

pub async fn subscribe_wallet_pnl<F>( &self, chain: &str, wallet_address: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to wallet PnL

pub async fn subscribe_new_tokens_metadata<F>( &self, chain: &str, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to new tokens metadata

pub async fn subscribe_ranking_tokens_list<F>( &self, chain: &str, ranking_type: RankingType, callback: F, filter: Option<&str>, ) -> Result<Unsubscribe, ChainStreamError>

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

Subscribe to ranking tokens list