Struct SubscribeClient 

pub struct SubscribeClient { /* private fields */ }

A WebSocket subscription client for the chain RPC.

Implementations

impl SubscribeClient

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

Connects to the chain RPC WebSocket endpoint.

endpoint may be a full ws:// / wss:// URL, or an http:// / https:// base URL (the scheme is upgraded and /websocket appended if absent). A background task pumps incoming frames to the per-subscription channels until the connection closes.

pub fn subscribe(&self, query: &str) -> Result<Subscription>

Registers a subscription for query and sends the subscribe request, returning the Subscription handle.

pub fn subscribe_new_blocks(&self) -> Result<Subscription>

Subscribes to committed blocks (QUERY_NEW_BLOCK).

pub fn subscribe_tx(&self, query: &str) -> Result<Subscription>

Subscribes to committed transactions matching query. An empty query subscribes to all transactions; a query without tm.event is AND-ed with QUERY_TX.