Struct ethers_contract::builders::Event

#[must_use = "event filters do nothing unless you `query` or `stream` them"]pub struct Event<'a: 'b, 'b, P, D> {
    pub filter: Filter,
    pub event: &'b AbiEvent,
    // some fields omitted
}

Helper for managing the event filter before querying or streaming its logs

Fields

filter: Filter

The event filter's state

event: &'b AbiEvent

The ABI of the event which is being filtered

Implementations

impl<'_, '_, P, D: Detokenize> Event<'_, '_, P, D>

pub fn from_block<T: Into<BlockNumber>>(self, block: T) -> Self

Sets the filter's from block

pub fn to_block<T: Into<BlockNumber>>(self, block: T) -> Self

Sets the filter's to block

pub fn topic0<T: Into<ValueOrArray<H256>>>(self, topic: T) -> Self

Sets the filter's 0th topic (typically the event name for non-anonymous events)

pub fn topic1<T: Into<ValueOrArray<H256>>>(self, topic: T) -> Self

Sets the filter's 1st topic

pub fn topic2<T: Into<ValueOrArray<H256>>>(self, topic: T) -> Self

Sets the filter's 2nd topic

pub fn topic3<T: Into<ValueOrArray<H256>>>(self, topic: T) -> Self

Sets the filter's 3rd topic

impl<'a, 'b, P, D> Event<'a, 'b, P, D> where
    P: JsonRpcClient,
    D: 'b + Detokenize + Clone,
    'a: 'b, 

pub async fn stream(
    self
) -> Result<impl Stream<Item = Result<D, ContractError>> + 'b, ContractError>

Returns a stream for the event

impl<'_, '_, P, D> Event<'_, '_, P, D> where
    P: JsonRpcClient,
    D: Detokenize + Clone, 

pub async fn query<'_>(&'_ self) -> Result<Vec<D>, ContractError>

Queries the blockchain for the selected filter and returns a vector of matching event logs

pub async fn query_with_hashes<'_>(
    &'_ self
) -> Result<HashMap<H256, D>, ContractError>

Queries the blockchain for the selected filter and returns a hashmap of txhash -> logs