remove callback

Author: LeoPatOZ

README.md

@@ -8,7 +8,7 @@
 
 ## About
 
-Event Scanner is a Rust library for monitoring EVM-based smart contract events. It is built on top of the [`alloy`](https://github.com/alloy-rs/alloy) ecosystem and focuses on in-memory scanning without a backing database. Applications provide event filters and callback implementations; the scanner takes care of subscribing to historical ranges, bridging into live mode, and delivering events with retry-aware execution strategies.
+Event Scanner is a Rust library for monitoring EVM-based smart contract events. It is built on top of the [`alloy`](https://github.com/alloy-rs/alloy) ecosystem and focuses on in-memory scanning without a backing database. Applications provide event filters; the scanner takes care of subscribing to historical ranges, bridging into live mode, all whilst delivering the events as streams.
 
 ---
 
@@ -31,7 +31,7 @@ Event Scanner is a Rust library for monitoring EVM-based smart contract events.
 - **Historical replay** – scan block ranges.
 - **Live subscriptions** – stay up to date with latest blocks via WebSocket or IPC transports.
 - **Hybrid flow** – automatically transition from historical catch-up into streaming mode.
-- **Composable filters** – register one or many contract + event signature pairs with their own callbacks.
+- **Composable filters** – register one or many contract + event signature pairs with their own event streams.
 - **No database** – processing happens in-memory; persistence is left to the host application.
 
 ---
@@ -55,37 +55,43 @@ Add `event-scanner` to your `Cargo.toml`:
 event-scanner = "0.1.0-alpha.1"
 ```
 
-```rust
-use std::{sync::{Arc, atomic::{AtomicUsize, Ordering}}};
-use alloy::{eips::BlockNumberOrTag, network::Ethereum, rpc::types::Log, sol_types::SolEvent};
-use async_trait::async_trait;
-use event_scanner::{event_scanner::EventScannerBuilder, EventCallback, EventFilter};
-
-struct CounterCallback { processed: Arc<AtomicUsize> }
-
-#[async_trait]
-impl EventCallback for CounterCallback {
-    async fn on_event(&self, _log: &Log) -> anyhow::Result<()> {
-        self.processed.fetch_add(1, Ordering::SeqCst);
-        Ok(())
-    }
-}
-
-async fn run_scanner(ws_url: alloy::transports::http::reqwest::Url, contract: alloy::primitives::Address) -> anyhow::Result<()> {
-    let filter = EventFilter::new()
-        .with_contract_address(contract)
-        .with_event(MyContract::SomeEvent::SIGNATURE)
-        .with_callback(Arc::new(CounterCallback { processed: Arc::new(AtomicUsize::new(0)) }));
-
-    let mut client = EventScannerBuilder::new()
-        .with_event_filter(filter)
-        .connect_ws::<Ethereum>(ws_url)
-        .await?;
-
-    client.start_scanner(BlockNumberOrTag::Latest, None).await?;
-    Ok(())
-}
-```
+ ```rust
+ use std::sync::{Arc, atomic::{AtomicUsize, Ordering}};
+ use alloy::{eips::BlockNumberOrTag, network::Ethereum, rpc::types::Log, sol_types::SolEvent};
+ use event_scanner::{event_filter::EventFilter, event_scanner::EventScanner};
+ use tokio_stream::StreamExt;
+
+ struct CounterHandler { };
+
+ impl CounterHandler {
+     async fn handle_event(&self, log: &Log) -> anyhow::Result<()> {
+         println!("Processed event: {:?}", log);
+         Ok(())
+     }
+ }
+
+ async fn run_scanner(ws_url: alloy::transports::http::reqwest::Url, contract: alloy::primitives::Address) -> anyhow::Result<()> {
+     let filter = EventFilter::new()
+         .with_contract_address(contract)
+         .with_event(MyContract::SomeEvent::SIGNATURE);
+
+     let mut client = EventScanner::new().connect_ws::<Ethereum>(ws_url).await?;
+     let mut stream = client.create_event_stream(filter);
+
+     tokio::spawn(async move {
+         client.start_scanner(BlockNumberOrTag::Latest, None).await
+     });
+
+     let handler = CounterHandler { };
+     while let Some(Ok(logs)) = stream.next().await {
+         for log in logs {
+             handler.handle_event(&log).await?;
+         }
+     }
+
+     Ok(())
+ }
+ ```
 
 ---
 
@@ -100,12 +106,12 @@ async fn run_scanner(ws_url: alloy::transports::http::reqwest::Url, contract: al
 - `with_reorg_rewind_depth` - how many blocks to rewind when a reorg is detected
 - `with_block_confirmations` - how many confirmations to wait for before considering a block final
 
-Once configured, connect using either `connect_ws::<Ethereum>(ws_url)` or `connect_ipc::<Ethereum>(path)`. This will `build` the `EventScanner` and allow you to call run to start in various [modes](#scanning-Modes).
+Once configured, connect using either `connect_ws::<Ethereum>(ws_url)` or `connect_ipc::<Ethereum>(path)`. This will build the `EventScanner` and allow you to create event streams and start scanning in various [modes](#scanning-modes).
 
 
 ### Defining Event Filters
 
-Create an `EventFilter` for each contract/event pair you want to track. The filter bundles the contract address, the event signature (from `SolEvent::SIGNATURE`).
+Create an `EventFilter` for each contract/event pair you want to track. The filter specifies the contract address and the event signature (from `SolEvent::SIGNATURE`).
 
 Both `contract_address` and `event` fields are optional, allowing for flexible event tracking.
 
@@ -169,7 +175,7 @@ This flexibility allows you to build sophisticated event monitoring systems that
 - **Historical mode** – `start(BlockNumberOrTag::Number(start, Some(BlockNumberOrTag::Number(end)))`, scanner fetches events from a historical block range.
 - **Historical → Live** – `start(BlockNumberOrTag::Number(start, None)` replays from `start` to current head, then streams future blocks.
 
-For now modes are deduced from the `start` and `end` parameters. In the future, we might add explicit commands to select the mode.
+For now modes are deduced from the `start` and `end` parameters. In the future, we might add explicit commands to select the mode. Use `create_event_stream` to obtain a stream of events for processing.
 
 See the integration tests under `tests/live_mode`, `tests/historic_mode`, and `tests/historic_to_live` for concrete examples.
 
@@ -188,7 +194,7 @@ RUST_LOG=info cargo run -p simple_counter
 RUST_LOG=info cargo run -p historical_scanning
 ```
 
-Both examples spin up a local `anvil` instance and deploy a demo counter contract before starting the scanner.
+Both examples spin up a local `anvil` instance, deploy a demo counter contract, and demonstrate using event streams to process events.
 
 ---