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 804fc7ea6..88d1c3de8 100644 --- a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs +++ b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs @@ -5,7 +5,7 @@ Err, Event, PduEvent, debug, debug_error, debug_info, debug_warn, err, error, state_res::lexicographical_topological_sort, trace, - utils::{IterStream, stream::BroadbandExt}, + utils::{IterStream, math::Expected, stream::BroadbandExt}, warn, }; use futures::{StreamExt, future::select_ok}; @@ -487,6 +487,7 @@ pub async fn get_missing_events( ); for iteration in 0..iteration_limit { let limit = iteration + .expected_add(1) .saturating_mul(10) .min(GET_MISSING_EVENTS_MAX_BATCH_SIZE); debug_info!(