Struct AttestedEvent

pub struct AttestedEvent<M: Middleware + 'static> { /* private fields */ }

Implementations

impl<M: Middleware> AttestedEvent<M>

pub fn new(filter: Event<Arc<M>, M, AttestedFilter>) -> Self

pub async fn stream( &self, ) -> Result<BoxStream<'_, Result<Attested, Error<M>>>, Error<M>>

Examples found in repository

examples/events.rs (line 28)

async fn main() -> Result<(), Box<dyn Error>> {
    let singing_key = &hex::decode(SEPOLIA_PRIVATE_KEY_HEX)?;
    let signing_key = SigningKey::from_slice(singing_key)?;
    let contract_address = H160::from_str(SEPOLIA_CONTRACT_ADDRESS)?;
    let client = client::Client::new(SEPOLIA_ENDPOINT, contract_address, None, signing_key).await?;

    // Filter for the events starting with the block ID 5553102
    let filter = client.eas.attested_event(5553102, None, None);

    // Get the query for the filter
    // This will return the logs that match the filter all at once
    let query = filter.query().await?;
    println!("Query: {:?}", query);

    // Get the stream for the filter
    let mut stream = filter.stream().await.expect("Failed to get stream");

    // This will print the logs as they come in
    while let Some(Ok(approval)) = stream.next().await {
        println!("Approval: {:?}", approval);
    }

    Ok(())
}

pub async fn query(&self) -> Result<Vec<Attested>, Error<M>>

Examples found in repository

examples/events.rs (line 24)

async fn main() -> Result<(), Box<dyn Error>> {
    let singing_key = &hex::decode(SEPOLIA_PRIVATE_KEY_HEX)?;
    let signing_key = SigningKey::from_slice(singing_key)?;
    let contract_address = H160::from_str(SEPOLIA_CONTRACT_ADDRESS)?;
    let client = client::Client::new(SEPOLIA_ENDPOINT, contract_address, None, signing_key).await?;

    // Filter for the events starting with the block ID 5553102
    let filter = client.eas.attested_event(5553102, None, None);

    // Get the query for the filter
    // This will return the logs that match the filter all at once
    let query = filter.query().await?;
    println!("Query: {:?}", query);

    // Get the stream for the filter
    let mut stream = filter.stream().await.expect("Failed to get stream");

    // This will print the logs as they come in
    while let Some(Ok(approval)) = stream.next().await {
        println!("Approval: {:?}", approval);
    }

    Ok(())
}

impl<M: Middleware> AttestedEvent<M>

where M::Provider: PubsubClient,

pub async fn subscribe( &self, ) -> Result<impl Stream<Item = Result<Attested, Error<M>>> + '_, Error<M>>