Skip to main content

EthFilterApiServer

reth::rpc::api

Trait EthFilterApiServer 

Source 
pub trait EthFilterApiServer<T, L>:
    Sized
    + Send
    + Sync
    + 'static
where
    T: RpcObject,
    L: RpcObject,
{
    // Required methods
    fn new_filter(
        &self,
        filter: Filter,
    ) -> impl Future<Output = Result<FilterId, ErrorObject<'static>>> + Send;
    fn new_block_filter(
        &self,
    ) -> impl Future<Output = Result<FilterId, ErrorObject<'static>>> + Send;
    fn new_pending_transaction_filter(
        &self,
        kind: Option<PendingTransactionFilterKind>,
    ) -> impl Future<Output = Result<FilterId, ErrorObject<'static>>> + Send;
    fn filter_changes(
        &self,
        id: FilterId,
    ) -> impl Future<Output = Result<FilterChanges<T, L>, ErrorObject<'static>>> + Send;
    fn filter_logs(
        &self,
        id: FilterId,
    ) -> impl Future<Output = Result<Vec<L>, ErrorObject<'static>>> + Send;
    fn uninstall_filter(
        &self,
        id: FilterId,
    ) -> impl Future<Output = Result<bool, ErrorObject<'static>>> + Send;
    fn logs(
        &self,
        filter: Filter,
    ) -> impl Future<Output = Result<Vec<L>, ErrorObject<'static>>> + Send;

    // Provided method
    fn into_rpc(self) -> RpcModule<Self>
       where T: Send + Sync + 'static + Clone + Serialize,
             L: Send + Sync + 'static + Clone + Serialize { ... }
}
Expand description

re-export of all server traits Server trait implementation for the EthFilterApi RPC API.

Required Methods§

Source

fn new_filter( &self, filter: Filter, ) -> impl Future<Output = Result<FilterId, ErrorObject<'static>>> + Send

Creates a new filter and returns its id.

Source

fn new_block_filter( &self, ) -> impl Future<Output = Result<FilterId, ErrorObject<'static>>> + Send

Creates a new block filter and returns its id.

Source

fn new_pending_transaction_filter( &self, kind: Option<PendingTransactionFilterKind>, ) -> impl Future<Output = Result<FilterId, ErrorObject<'static>>> + Send

Creates a pending transaction filter and returns its id.

Source

fn filter_changes( &self, id: FilterId, ) -> impl Future<Output = Result<FilterChanges<T, L>, ErrorObject<'static>>> + Send

Returns all filter changes since last poll.

Source

fn filter_logs( &self, id: FilterId, ) -> impl Future<Output = Result<Vec<L>, ErrorObject<'static>>> + Send

Returns all logs matching given filter (in a range ‘from’ - ‘to’).

Source

fn uninstall_filter( &self, id: FilterId, ) -> impl Future<Output = Result<bool, ErrorObject<'static>>> + Send

Uninstalls filter.

Source

fn logs( &self, filter: Filter, ) -> impl Future<Output = Result<Vec<L>, ErrorObject<'static>>> + Send

Returns logs matching given filter object.

Provided Methods§

Source

fn into_rpc(self) -> RpcModule<Self>
where T: Send + Sync + 'static + Clone + Serialize, L: Send + Sync + 'static + Clone + Serialize,

Collects all the methods and subscriptions defined in the trait and adds them into a single RpcModule.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§