Skip to content

Commit 633f473

Browse files
committed
update logging
1 parent 6306daf commit 633f473

File tree

1 file changed

+6
-9
lines changed

1 file changed

+6
-9
lines changed

src/event_scanner.rs

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -139,8 +139,8 @@ impl<N: Network> ConnectedEventScanner<N> {
139139
self.spawn_log_consumers(&range_tx);
140140

141141
while let Some(message) = stream.next().await {
142-
if let Err(send_err) = range_tx.send(message) {
143-
error!(error = %send_err, "failed to send error");
142+
if let Err(err) = range_tx.send(message) {
143+
error!(error = %err, "failed sending message to broadcast channel");
144144
}
145145
}
146146

@@ -220,16 +220,13 @@ impl<N: Network> ConnectedEventScanner<N> {
220220
}
221221
}
222222
Ok(BlockRangeMessage::Error(e)) => {
223-
if let Err(send_err) =
224-
sender.send(ScannerMessage::Error(e.into())).await
225-
{
226-
error!(error = %send_err, "failed to send error to broadcast channel");
223+
if let Err(err) = sender.send(ScannerMessage::Error(e.into())).await {
224+
error!(error = %err, "failed to propagate error to receiver stream");
227225
}
228226
}
229227
Ok(BlockRangeMessage::Status(status)) => {
230-
if let Err(send_err) = sender.send(ScannerMessage::Status(status)).await
231-
{
232-
error!(error = %send_err, "failed to send error to");
228+
if let Err(err) = sender.send(ScannerMessage::Status(status)).await {
229+
error!(error = %err, "failed to send info to receiver stream");
233230
}
234231
}
235232
// TODO: What happens if the broadcast channel is closed?

0 commit comments

Comments
 (0)