Skip to main content

WatchBlocks

alloy_provider

Struct WatchBlocks 

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

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§

Source§

impl<BlockResp> WatchBlocks<BlockResp>
where BlockResp: BlockResponse + RpcRecv,

Source

pub const fn full(self) -> Self

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

Source

pub const fn hashes(self) -> Self

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

Source

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

Sets the channel size for the poller task.

Source

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

Sets a limit on the number of successful polls.

Source

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

Sets the duration between polls.

Source

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§

Source§

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

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<BlockResp> Freeze for WatchBlocks<BlockResp>

§

impl<BlockResp> !RefUnwindSafe for WatchBlocks<BlockResp>

§

impl<BlockResp> Send for WatchBlocks<BlockResp>
where BlockResp: Send,

§

impl<BlockResp> Sync for WatchBlocks<BlockResp>
where BlockResp: Sync,

§

impl<BlockResp> Unpin for WatchBlocks<BlockResp>
where BlockResp: Unpin,

§

impl<BlockResp> UnsafeUnpin for WatchBlocks<BlockResp>

§

impl<BlockResp> !UnwindSafe for WatchBlocks<BlockResp>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

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: 152 bytes