diff options
Diffstat (limited to 'broadcast/src/handler.rs')
| -rw-r--r-- | broadcast/src/handler.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/broadcast/src/handler.rs b/broadcast/src/handler.rs index 5ebed27..d4bb94a 100644 --- a/broadcast/src/handler.rs +++ b/broadcast/src/handler.rs @@ -101,13 +101,15 @@ impl Handler for BroadcastHandler { .await } - // Ignore OK messages - we never actually request them BroadcastBody::BroadcastOk { in_reply_to } => { + // Stop retrying, if we still are if let Some(task) = self.attempted_broadcasts.lock().await.remove(&in_reply_to) { task.cancel().await; } } + + // Ignore other OK messages - we never actually request them BroadcastBody::TopologyOk { .. } => {} BroadcastBody::ReadOk { .. } => {} } |