Struct HyperSyncClient

pub struct HyperSyncClient { /* private fields */ }

A client for interacting with a HyperSync API to retrieve blockchain data.

Implementations

impl HyperSyncClient

pub fn new(chain: SharedChain, tx: UnboundedSender<BlockchainMessage>) -> Self

Creates a new HyperSyncClient instance for the given chain and message sender.

Panics

Panics if the chain’s hypersync_url is invalid or if the underlying client cannot be initialized.

pub async fn request_contract_events_stream( &self, from_block: u64, to_block: Option<u64>, contract_address: &str, event_signature: &str, additional_topics: Vec<String>, ) -> impl Stream<Item = Log> + use<>

Creates a stream of contract event logs matching the specified criteria.

pub fn disconnect(&mut self)

Disconnects from the HyperSync service and stops all background tasks.

pub async fn current_block(&self) -> u64

Returns the current block

pub async fn request_blocks_stream( &self, from_block: u64, to_block: Option<u64>, ) -> impl Stream<Item = Block>

Creates a stream that yields blockchain blocks within the specified range.

pub fn subscribe_blocks(&mut self)

Starts a background task that continuously polls for new blockchain blocks.

pub fn subscribe_pool_swaps(&mut self, pool_address: Address)

Subscribes to swap events for a specific pool address.

pub fn unsubscribe_pool_swaps(&mut self, pool_address: Address)

Unsubscribes from swap events for a specific pool address.

pub fn unsubscribe_all_swaps(&mut self)

Unsubscribes from all swap events by stopping all swap background tasks.

pub fn unsubscribe_blocks(&mut self)

Unsubscribes from new blocks by stopping the background watch task.

Trait Implementations

impl Debug for HyperSyncClient

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

Formats the value using the given formatter.