git-mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-09-10 05:02:49 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(fed): Handle EDUs before PDUs

Browse source 
Aranje needs his crypto keys
This commit is contained in:
nexy7574 2025-08-25 21:26:56 +01:00
commit 7d9ec7a0e5
No known key found for this signature in database
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/api/server/send.rs
View file

@ -143,6 +143,10 @@ async fn handle(
pdus: impl Stream<Item = Pdu> + Send, pdus: impl Stream<Item = Pdu> + Send,
edus: impl Stream<Item = Edu> + Send, edus: impl Stream<Item = Edu> + Send,
) -> Result<ResolvedMap> { ) -> Result<ResolvedMap> {
edus.for_each_concurrent(automatic_width(), |edu| handle_edu(services, client, origin, edu))
.boxed()
.await;
// group pdus by room // group pdus by room
let pdus = pdus let pdus = pdus
.collect() .collect()
@ -169,11 +173,6 @@ async fn handle(
.boxed() .boxed()
.await?; .await?;
// evaluate edus after pdus, at least for now.
edus.for_each_concurrent(automatic_width(), |edu| handle_edu(services, client, origin, edu))
.boxed()
.await;
Ok(results) Ok(results)
} }