Struct StreamHandler 

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

Streams logs to listeners as soon as each scanned block range is processed.

This handler fetches logs per listener and forwards each non-empty result immediately. It is used by scanner modes that operate as continuous streams (e.g. historic/live scanning), where incremental delivery is preferred over collecting a fixed-size window.

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> StreamHandler<N>

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

Creates a StreamHandler.

Arguments

• provider - The robust provider for making RPC calls
• listeners - The list of event listeners to stream logs to
• max_concurrent_fetches - Limits how many log-fetching RPC requests can be in-flight per listener at once.
• broadcast_channel_capacity - Capacity for the broadcast channel used to distribute block ranges to consumers.

Trait Implementations

impl<N: Network> BlockRangeHandler for StreamHandler<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 StreamHandler<N>

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

Formats the value using the given formatter.