Struct EventSubscription 

pub struct EventSubscription { /* private fields */ }

A subscription to scanner events that requires proof the scanner has started.

Created by EventScanner::subscribe(), this type holds the underlying stream but prevents access until stream() is called with a valid StartProof.

This pattern ensures at compile time that EventScanner::start() is called before attempting to read from the event stream.

Example

let mut scanner = EventScannerBuilder::live().connect(provider).await?;

let filter = EventFilter::new().contract_address(contract_address);

// Create subscription (cannot access stream yet)
let subscription = scanner.subscribe(filter);

// Start scanner and get proof of it starting
let proof = scanner.start().await?;

// Now access the stream with the proof
let mut stream = subscription.stream(&proof);

while let Some(msg) = stream.next().await {
    // process events
}

Implementations

impl EventSubscription

pub fn stream(self, _proof: &StartProof) -> ReceiverStream<EventScannerResult>

Access the event stream.

Requires a reference to a StartProof as proof that the scanner has been started. The proof is obtained by calling EventScanner::start().

Arguments

• _proof - Proof that the scanner has been started