Struct WatchBlocksFrom 

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

A builder for streaming blocks from a historical block and continuing indefinitely.

Implementations

impl<N: Network> WatchBlocksFrom<N>

pub const fn full(self) -> Self

Streams blocks with full transaction bodies.

pub const fn hashes(self) -> Self

Streams blocks with transaction hashes only.

pub const fn poll_interval(self, poll_interval: Duration) -> Self

Sets the poll interval used when the stream is caught up.

pub const fn block_tag(self, block_tag: BlockNumberOrTag) -> Self

Sets the head block tag used to determine stream progress.

pub const fn canonical(self) -> WatchCanonicalBlocksFrom<N>

Converts this builder into a canonical-stream builder that emits crate::CanonicalEvent deltas on reorgs.

pub const fn into_stream(self) -> WatchBlocksFromStream<N>

Stream blocks from a historical block using sequential eth_getBlockByNumber calls.

This stream continues polling after catching up and continues yielding new blocks indefinitely.

This stream does not handle reorgs. Instead, each item yielded from the stream is strictly ordered in terms of block number, regardless of the blocks parent.

For example (height, hash, parent):

You should expect blocks in order by number with no gaps and with disjoint parents: [(1, 1A, 0A),(2, 2A, 1A),(3,3B,2B)]

And you should not expect receiving two blocks with the same number: [(1, 1A, 0A),(2, 2A, 1A),(2,2B,1A)]

Each yielded future contains one block request.

If a block request returns NullResp, the yielded future retries the same block until it succeeds.

Other errors are surfaced to the caller. Configure retries on the underlying client transport (for example with RetryBackoffLayer) for transport-level retry behavior.

This can be buffered by the caller, for example with StreamExt::buffered.

Trait Implementations

impl<N: Clone + Network> Clone for WatchBlocksFrom<N>

fn clone(&self) -> WatchBlocksFrom<N>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 56 bytes