From cdc50aa79d30f8dc7adc1f4302836a365c26a139 Mon Sep 17 00:00:00 2001 From: Nicolas Koch Date: Mon, 6 Dec 2021 14:02:18 +0100 Subject: [PATCH] Update previous state during compensation. Fixes #53 --- src/sync_stream.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/src/sync_stream.rs b/src/sync_stream.rs index 14dba2f..8667e19 100644 --- a/src/sync_stream.rs +++ b/src/sync_stream.rs @@ -497,6 +497,7 @@ impl<'a> Iterator for FetchEventsSynced<'a> { // first: check if we need to emit compensatory events due to a SYN_DROPPED we found in the // last batch of blocks if let Some(ev) = compensate_events(&mut self.sync, &mut self.dev) { + self.dev.prev_state.process_event(ev); return Some(ev); } let state = &mut self.dev.state;