Struct WatchBlocks

pub struct WatchBlocks<BlockResp> { /* private fields */ }

A builder type for polling new blocks using the FilterPollerBuilder.

By default, this polls for blocks with BlockTransactionsKind::Hashes.

WatchBlocks::full should be used to poll for blocks with BlockTransactionsKind::Full.

The polling stream must be consumed by calling WatchBlocks::into_stream.

Implementations

impl<BlockResp> WatchBlocks<BlockResp>

where BlockResp: BlockResponse + RpcRecv,

pub const fn full(self) -> Self

Poll for blocks with full transactions i.e BlockTransactionsKind::Full.

pub const fn hashes(self) -> Self

Poll for blocks with just transactions hashes i.e BlockTransactionsKind::Hashes.

pub fn set_channel_size(&mut self, channel_size: usize)

Sets the channel size for the poller task.

pub fn set_limit(&mut self, limit: Option<usize>)

Sets a limit on the number of successful polls.

pub fn set_poll_interval(&mut self, poll_interval: Duration)

Sets the duration between polls.

pub fn into_stream( self, ) -> impl Stream<Item = TransportResult<BlockResp>> + Unpin

Consumes the stream of block hashes from the inner FilterPollerBuilder and maps it to a stream of BlockResponse.

Trait Implementations

impl<BlockResp: Debug> Debug for WatchBlocks<BlockResp>

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

Formats the value using the given formatter.