mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2026-11-13 20:26:52 +00:00
fix: Don't try and fetch zero events
This commit is contained in:
1 parent
c6acbf5440
commit
a3544ba01f
1 file changed
+2
-1
@@ -5,7 +5,7 @@ use conduwuit::{
|
||||
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 @@ impl super::Service {
|
||||
);
|
||||
for iteration in 0..iteration_limit {
|
||||
let limit = iteration
|
||||
.expected_add(1)
|
||||
.saturating_mul(10)
|
||||
.min(GET_MISSING_EVENTS_MAX_BATCH_SIZE);
|
||||
debug_info!(
|
||||
|
||||
Reference in new issue
Block a user