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