diff --git a/plume-common/src/activity_pub/mod.rs b/plume-common/src/activity_pub/mod.rs index bb7ea792..73632eed 100644 --- a/plume-common/src/activity_pub/mod.rs +++ b/plume-common/src/activity_pub/mod.rs @@ -157,7 +157,7 @@ where .build() .expect("Error while initializing tokio runtime for federation"); rt.block_on(async { - let capacity = 50; + let capacity = 6; let (tx, rx) = flume::bounded::(capacity); let mut handles = Vec::with_capacity(capacity); for _ in 0..capacity {