Correctly pre-allocate number of receivers (#197)

yoshidan · Oct 10, 2023 · 49d30b0 · 49d30b0
1 parent 85423c3
commit 49d30b0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pubsub/src/publisher.rs b/pubsub/src/publisher.rs
@@ -80,7 +80,7 @@ impl Publisher {
     pub(crate) fn new(fqtn: String, pubc: PublisherClient, config: Option<PublisherConfig>) -> Self {
         let config = config.unwrap_or_default();
         let (sender, receiver) = async_channel::unbounded::<Reserved>();
-        let mut receivers = Vec::with_capacity(1 + config.workers);
+        let mut receivers = Vec::with_capacity(config.workers * 2);
         let mut ordering_senders = Vec::with_capacity(config.workers);
 
         // for non-ordering key message