Skip to content

Commit 628d656

Browse files
committed
dedupe error
1 parent 130802c commit 628d656

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

plugins/listener/src/fsm.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -202,14 +202,14 @@ impl Session {
202202
.collect();
203203

204204
for &sample in &mixed {
205-
if let Err(e) = process_tx.send(sample).await {
206-
tracing::error!("process_tx_send_error: {:?}", e.0);
205+
if let Err(_) = process_tx.send(sample).await {
206+
tracing::error!("process_tx_send_error");
207207
return;
208208
}
209209

210210
if record {
211-
if let Err(e) = save_tx.send(sample).await {
212-
tracing::error!("save_tx_send_error: {:?}", e.0);
211+
if let Err(_) = save_tx.send(sample).await {
212+
tracing::error!("save_tx_send_error");
213213
}
214214
}
215215
}

0 commit comments

Comments
 (0)