Trait chaindexing::Streamable

source · 
pub trait Streamable {
    type StreamConn<'a>;

    // Required methods
    fn get_contract_addresses_stream<'a>(
        conn: Arc<Mutex<Self::StreamConn<'a>>>
    ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>;
    fn get_contract_addresses_stream_by_chain<'a>(
        conn: Arc<Mutex<Self::StreamConn<'a>>>,
        chain_id_: i64
    ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>;
    fn get_events_stream<'a>(
        conn: Arc<Mutex<Self::StreamConn<'a>>>,
        from: i64,
        chain_id_: i64,
        contract_address_: String
    ) -> Box<dyn Stream<Item = Vec<Event>> + Send + Unpin + 'a>;
}

Required Associated Types§

source

type StreamConn<'a>

Required Methods§

source

fn get_contract_addresses_stream<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>> ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>

source

fn get_contract_addresses_stream_by_chain<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>>, chain_id_: i64 ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>

source

fn get_events_stream<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>>, from: i64, chain_id_: i64, contract_address_: String ) -> Box<dyn Stream<Item = Vec<Event>> + Send + Unpin + 'a>

Object Safety§

This trait is not object safe.

Implementors§