diff --git a/src/api/server/send.rs b/src/api/server/send.rs index 86832bc6..e7e4e9fd 100644 --- a/src/api/server/send.rs +++ b/src/api/server/send.rs @@ -143,6 +143,10 @@ async fn handle( pdus: impl Stream + Send, edus: impl Stream + Send, ) -> Result { + edus.for_each_concurrent(automatic_width(), |edu| handle_edu(services, client, origin, edu)) + .boxed() + .await; + // group pdus by room let pdus = pdus .collect() @@ -169,11 +173,6 @@ async fn handle( .boxed() .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) }