feat: poll for events on outbox query
This commit is contained in:
parent
d03c338a82
commit
c0cfc103d0
1 changed files with 5 additions and 3 deletions
|
@ -213,7 +213,11 @@ async fn handler(
|
||||||
u
|
u
|
||||||
};
|
};
|
||||||
|
|
||||||
if Some(100) == q.page {
|
// if Some(100) == q.page {
|
||||||
|
|
||||||
|
// }
|
||||||
|
|
||||||
|
let res = if q.page.is_none() {
|
||||||
poll_person_util(
|
poll_person_util(
|
||||||
person.clone(),
|
person.clone(),
|
||||||
forge.clone(),
|
forge.clone(),
|
||||||
|
@ -231,9 +235,7 @@ async fn handler(
|
||||||
settings.clone(),
|
settings.clone(),
|
||||||
)
|
)
|
||||||
.await?;
|
.await?;
|
||||||
}
|
|
||||||
|
|
||||||
let res = if q.page.is_none() {
|
|
||||||
let count = cache_ap_local_obect_service
|
let count = cache_ap_local_obect_service
|
||||||
.get_total_acitivites_by_person(&person, Visibility::Public)
|
.get_total_acitivites_by_person(&person, Visibility::Public)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
Loading…
Reference in a new issue