Struct EventsClient 

pub struct EventsClient { /* private fields */ }

Client for subscribing to and streaming GolemBase events from the blockchain. Provides methods to connect to a node and receive event streams for entity changes.

Implementations

impl EventsClient

pub async fn new(url: Url) -> Result<Self>

Creates a new EventsClient by connecting to the given websocket Url. Establishes a connection to the blockchain node for event streaming.

pub async fn events_stream<'a>( &'a self, ) -> Result<Pin<Box<dyn Stream<Item = Result<Event>> + Send + 'a>>>

Listens for GolemBase events from the blockchain, starting from the latest block. Returns a stream of parsed Event items that can be processed asynchronously.

pub async fn events_stream_from_block<'a>( &'a self, block: u64, ) -> Result<Pin<Box<dyn Stream<Item = Result<Event>> + Send + 'a>>>

Listens for GolemBase events starting from a specific block number. Returns a stream of parsed Event items from the given block onward.

Arguments

• block - The block number to start listening for events from.