Skip to content

Commit 0cc478c

Browse files
flatten
1 parent c8184ba commit 0cc478c

1 file changed

Lines changed: 3 additions & 5 deletions

File tree

follower/src/resolver.rs

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -224,11 +224,9 @@ impl<E: Spawner + Clock + CryptoRng + RngCore, C: Source> Actor<E, C> {
224224
.collect::<Vec<_>>();
225225
let removed = to_remove.len();
226226
for key in to_remove {
227-
if let Some(state) = self.requests.remove(&key) {
228-
if let State::Scheduled(deadline) = state {
229-
let removed = self.retry_schedule.remove(&(deadline, key.clone()));
230-
assert!(removed, "scheduled retry entry missing");
231-
}
227+
if let Some(State::Scheduled(deadline)) = self.requests.remove(&key) {
228+
let removed = self.retry_schedule.remove(&(deadline, key.clone()));
229+
assert!(removed, "scheduled retry entry missing");
232230
}
233231
}
234232
debug!(removed, remaining = self.requests.len(), "retained pending requests");

0 commit comments

Comments
 (0)