Struct LatestEventsHandler 

pub struct LatestEventsHandler<N: Network> { /* private fields */ }

Collects the latest count logs per listener before streaming them.

This handler performs a reverse scan (newest-to-oldest) while buffering logs locally. Once count matching logs are collected (or the scan finishes), it emits the collected logs in chronological order (oldest-to-newest) and stops.

During reorg recovery it prepends newly fetched logs so that the newest-first buffer remains correctly ordered.

Concurrency

The max_concurrent_fetches limit applies per listener, not globally. With N listeners and a limit of M, up to N × M concurrent RPC requests may be in-flight simultaneously.

Implementations

impl<N: Network> LatestEventsHandler<N>

pub fn new( provider: RobustProvider<N>, listeners: Vec<EventListener>, max_concurrent_fetches: usize, count: usize, broadcast_channel_capacity: usize, ) -> Self

Creates a LatestEventsHandler.

Arguments

• provider - The robust provider to use for fetching logs
• listeners - The list of event listeners to collect logs for
• max_concurrent_fetches - Maximum number of concurrent log-fetching RPC requests per listener
• count - Maximum number of logs to collect per listener before streaming
• broadcast_channel_capacity - Capacity of the broadcast channel for forwarding results

Trait Implementations

impl<N: Network> BlockRangeHandler for LatestEventsHandler<N>

async fn handle<S: Stream<Item = BlockScannerResult> + Unpin + Send>( self, stream: S, )

Consumes a stream of scanned block-range results.

impl<N: Debug + Network> Debug for LatestEventsHandler<N>

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

Formats the value using the given formatter.