Client::sync_forever(): Add filter in next iteration.
@@ -1314,6 +1314,7 @@ impl Client {
C: Future<Output = ()>,
{
let mut sync_settings = sync_settings;
+ let filter = sync_settings.filter.clone();
let mut last_sync_time: Option<Instant> = None;
if sync_settings.token.is_none() {
@@ -1373,6 +1374,9 @@ impl Client {
.await
.expect("No sync token found after initial sync"),
);
+ if let Some(f) = filter.as_ref() {
+ sync_settings = sync_settings.filter(f.clone());
+ }
}
}
