Module filter 

support for polling filters Support for polling based filters

Re-exports

use crate::StorageInfo; 🔒

use crate::eth::backend::notifications::ChainNotification; 🔒

use crate::eth::backend::notifications::ChainNotifications; 🔒

use crate::eth::error::ToRpcResponseResult; 🔒

use crate::pubsub::filter_logs; 🔒

use crate::pubsub::filter_removed_logs; 🔒

use alloy_consensus::TxReceipt; 🔒

use alloy_network::AnyRpcTransaction; 🔒

use alloy_network::Network; 🔒

use alloy_primitives::TxHash; 🔒

use alloy_primitives::map::HashMap; 🔒

use alloy_rpc_types::Filter; 🔒

use alloy_rpc_types::FilteredParams; 🔒

use alloy_rpc_types::Log; 🔒

use anvil_core::eth::subscription::SubscriptionId; 🔒

use anvil_rpc::error::ErrorCode; 🔒

use anvil_rpc::error::RpcError; 🔒

use anvil_rpc::response::ResponseResult; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use futures::channel::mpsc::Receiver; 🔒

use std::pin::Pin; 🔒

use std::sync::Arc; 🔒

use std::task::Context; 🔒

use std::task::Poll; 🔒

use std::time::Duration; 🔒

use std::time::Instant; 🔒

use tokio::sync::Mutex; 🔒

use tokio::sync::mpsc; 🔒

Structs

Filters

Contains all registered filters

LogsFilter

Listens for new blocks and matching logs emitted in that block

Enums

EthFilter

Represents a poll based filter

Constants

ACTIVE_FILTER_TIMEOUT_SECS

timeout after which to remove an active filter if it wasn’t polled since then

Functions

new_id 🔒

returns a new random hex id

Type Aliases

FilterMap 🔒

Type alias for filters identified by their id and their expiration timestamp