Revert "reduce rust version to 1.71 & edition to 2021"

This reverts commit 8a34075.

Author: 0xNeshi

Cargo.toml

@@ -9,8 +9,7 @@ categories = [
 ]
 keywords = ["evm", "ethereum", "blockchain", "events", "alloy"]
 authors = ["OpenZeppelin"]
-edition = "2021"
-rust-version = "1.71"
+edition = "2024"
 readme = "README.md"
 license = "MIT"
 repository = "https://github.com/OpenZeppelin/Event-Scanner"

rust-toolchain.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "1.71"
+channel = "1.89"

src/event_scanner/block_range_handler.rs

@@ -8,25 +8,25 @@
 use std::ops::RangeInclusive;
 
 use crate::{
+    Message, Notification, ScannerError, ScannerMessage,
     block_range_scanner::BlockScannerResult,
     event_scanner::{filter::EventFilter, listener::EventListener},
     types::TryStream,
-    Message, Notification, ScannerError, ScannerMessage,
 };
 use alloy::{
     network::Network,
     rpc::types::{Filter, Log},
 };
 use futures::StreamExt;
-use robust_provider::{provider::Error as RobustProviderError, RobustProvider};
+use robust_provider::{RobustProvider, provider::Error as RobustProviderError};
 use tokio::{
     sync::{
-        broadcast::{self, error::RecvError, Sender},
+        broadcast::{self, Sender, error::RecvError},
         mpsc,
     },
     task::JoinSet,
 };
-use tokio_stream::{wrappers::ReceiverStream, Stream};
+use tokio_stream::{Stream, wrappers::ReceiverStream};
 
 /// Handles a stream of scanned block ranges.
 pub trait BlockRangeHandler {
@@ -117,10 +117,10 @@ impl<N: Network> StreamHandler<N> {
 
                     // process all of the buffered results
                     while let Some(result) = stream.next().await {
-                        if let Ok(ScannerMessage::Data(logs)) = result.as_ref() {
-                            if logs.is_empty() {
-                                continue;
-                            }
+                        if let Ok(ScannerMessage::Data(logs)) = result.as_ref() &&
+                            logs.is_empty()
+                        {
+                            continue;
                         }
 
                         if listener.sender.try_stream(result).await.is_closed() {
@@ -491,7 +491,7 @@ async fn get_logs<N: Network>(
 mod tests {
     use alloy::{
         network::Ethereum,
-        providers::{mock::Asserter, RootProvider},
+        providers::{RootProvider, mock::Asserter},
         rpc::client::RpcClient,
     };