Remove scanner error enum

examples/historical_scanning/main.rs

@@ -69,17 +69,17 @@ async fn main() -> anyhow::Result<()> {
 
     while let Some(message) = stream.next().await {
         match message {
-            Message::Data(logs) => {
+            Ok(Message::Data(logs)) => {
                 for log in logs {
                     info!("Callback successfully executed with event {:?}", log.inner.data);
                 }
             }
-            Message::Error(e) => {
-                error!("Received error: {}", e);
-            }
-            Message::Notification(info) => {
+            Ok(Message::Notification(info)) => {
                 info!("Received info: {:?}", info);
             }
+            Err(e) => {
+                error!("Received error: {}", e);
+            }
         }
     }
 

examples/latest_events_scanning/main.rs

@@ -70,17 +70,17 @@ async fn main() -> anyhow::Result<()> {
 
     while let Some(message) = stream.next().await {
         match message {
-            Message::Data(logs) => {
+            Ok(Message::Data(logs)) => {
                 for log in logs {
                     info!("Received event: {:?}", log.inner.data);
                 }
             }
-            Message::Error(e) => {
-                error!("Received error: {}", e);
-            }
-            Message::Notification(info) => {
+            Ok(Message::Notification(info)) => {
                 info!("Received notification: {:?}", info);
             }
+            Err(e) => {
+                error!("Received error: {}", e);
+            }
         }
     }
 

examples/live_scanning/main.rs

@@ -69,17 +69,17 @@ async fn main() -> anyhow::Result<()> {
 
     while let Some(message) = stream.next().await {
         match message {
-            Message::Data(logs) => {
+            Ok(Message::Data(logs)) => {
                 for log in logs {
                     info!("Callback successfully executed with event {:?}", log.inner.data);
                 }
             }
-            Message::Error(e) => {
-                error!("Received error: {}", e);
-            }
-            Message::Notification(info) => {
+            Ok(Message::Notification(info)) => {
                 info!("Received info: {:?}", info);
             }
+            Err(e) => {
+                error!("Received error: {}", e);
+            }
         }
     }
 

examples/sync_from_block_scanning/main.rs

@@ -86,7 +86,7 @@ async fn main() -> anyhow::Result<()> {
 
     while let Some(message) = stream.next().await {
         match message {
-            Message::Data(logs) => {
+            Ok(Message::Data(logs)) => {
                 for log in logs {
                     let Counter::CountIncreased { newCount } = log.log_decode().unwrap().inner.data;
                     if newCount <= 3 {
@@ -98,12 +98,12 @@ async fn main() -> anyhow::Result<()> {
                     }
                 }
             }
-            Message::Error(e) => {
-                error!("Received error: {}", e);
-            }
-            Message::Notification(info) => {
+            Ok(Message::Notification(info)) => {
                 info!("Received notification: {:?}", info);
             }
+            Err(e) => {
+                error!("Received error: {}", e);
+            }
         }
 
         if historical_processed && live_processed {

examples/sync_from_latest_scanning/main.rs

@@ -77,17 +77,17 @@ async fn main() -> anyhow::Result<()> {
     // only the last 5 events will be streamed before switching to live mode
     while let Some(message) = stream.next().await {
         match message {
-            Message::Data(logs) => {
+            Ok(Message::Data(logs)) => {
                 for log in logs {
                     info!("Callback successfully executed with event {:?}", log.inner.data);
                 }
             }
-            Message::Error(e) => {
-                error!("Received error: {}", e);
-            }
-            Message::Notification(info) => {
+            Ok(Message::Notification(info)) => {
                 info!("Received info: {:?}", info);
             }
+            Err(e) => {
+                error!("Received error: {}", e);
+            }
         }
     }