Skip to content

Commit 0fc1783

Browse files
committed
fix: clone only ws_sink instead of entry
1 parent e1261c0 commit 0fc1783

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

crates/batcher/src/lib.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -669,22 +669,22 @@ impl Batcher {
669669
}
670670
};
671671

672-
let removed_entries: Vec<_> = batch_state_guard
672+
let removed_entries = batch_state_guard
673673
.batch_queue
674-
.extract_if(|entry, _| entry.sender == user_address)
675-
.collect();
674+
.extract_if(|entry, _| entry.sender == user_address);
676675

677676
// Notify user via websocket before removing the proofs
678677
for (entry, _) in removed_entries {
679678
if let Some(ws_sink) = entry.messaging_sink {
679+
let ws_sink_clone = ws_sink.clone();
680680
tokio::spawn(async move {
681681
send_message(
682-
ws_sink.clone(),
682+
ws_sink_clone.clone(),
683683
SubmitProofResponseMessage::UserFundsUnlocked,
684684
)
685685
.await;
686686
// Close websocket connection
687-
let mut sink_guard = ws_sink.write().await;
687+
let mut sink_guard = ws_sink_clone.write().await;
688688
if let Err(e) = sink_guard.close().await {
689689
warn!(
690690
"Error closing websocket for user {:?}: {:?}",

0 commit comments

Comments
 (0)