diff --git a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs index b4285be37..3813e10db 100644 --- a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs +++ b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs @@ -155,7 +155,12 @@ impl super::Service { .prev_events() .stream() .fold(0_u8, |i, event_id| async move { - if self.services.timeline.pdu_exists(event_id).await { + if self + .services + .timeline + .non_outlier_pdu_exists(event_id) + .await + { i } else { i.expected_add(1)