Skip to content

Commit 53063a3

Browse files
committed
ref: add batch match
1 parent 2fe0b47 commit 53063a3

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/robust_provider/subscription.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,14 @@ impl<N: Network> RobustSubscription<N> {
124124
return Ok(header);
125125
}
126126
Err(recv_error) => {
127+
match recv_error {
128+
RecvError::Closed => {
129+
error!("Provider closed the subscription channel");
130+
}
131+
RecvError::Lagged(count) => {
132+
error!(skipped = count, "Receiver lagged");
133+
}
134+
}
127135
return Err(recv_error.into());
128136
}
129137
},

0 commit comments

Comments
 (0)