We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a250537 commit 52232e5Copy full SHA for 52232e5
src/types.rs
@@ -4,10 +4,19 @@ use alloy::primitives::BlockHash;
4
use tokio::sync::mpsc;
5
use tracing::{info, warn};
6
7
+/// Messages streamed by the scanner to subscribers.
8
+///
9
+/// Each message represents either data (logs), an error, or a notification about the scanner's
10
+/// state or behavior.
11
#[derive(Copy, Debug, Clone)]
12
pub enum ScannerMessage<T: Clone, E: Error + Clone> {
13
+ /// Data streamed to the subscriber.
14
Data(T),
15
+
16
+ /// Error encountered during scanning.
17
Error(E),
18
19
+ /// Notification about scanner state changes or important events.
20
Notification(Notification),
21
}
22
0 commit comments