Struct MultiplexedPollerBuilder 

pub struct MultiplexedPollerBuilder { /* private fields */ }

Accumulates Routes and builds a MultiplexedPoller.

Implementations

impl MultiplexedPollerBuilder

pub fn new(head: Arc<dyn HeadSource>, poll_interval: Duration) -> Self

Construct with the defaults every route shares: the deploy floor (0), DEFAULT_GET_LOGS_MAX_BLOCK_SPAN, and the default watcher backoff schedule.

pub fn route(self, route: Route) -> Self

Register one watcher’s route.

pub const fn max_backfill_span(self, span: u64) -> Self

Set the block-span ceiling per eth_getLogs window (blockchain.get_logs_max_block_span). The poller starts there, shrinks below it on a provider range rejection and regrows back to it. Self::build rejects 0.

pub fn build(self) -> Result<MultiplexedPoller>

Build the poller: construct the merged filter and the (address, topic0) -> route demux index. Returns Err if two routes claim the same (address, topic0) key — two watchers subscribing to the same event is a wiring bug, not a runtime condition, so it fails fast at startup rather than silently routing every such log to whichever route happened to register first.

Trait Implementations

impl Debug for MultiplexedPollerBuilder

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

Formats the value using the given formatter.