From b6dcf619955f8c82fe0ae30093bbb84fa8ddca6c Mon Sep 17 00:00:00 2001
From: Tony Klink <antonyklink@gmail.com>
Date: Mon, 19 Feb 2024 10:47:49 -0600
Subject: [PATCH] Increase channel capacity

---
 src/bussy/mod.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/bussy/mod.rs b/src/bussy/mod.rs
index 147d5d9..738293d 100644
--- a/src/bussy/mod.rs
+++ b/src/bussy/mod.rs
@@ -112,7 +112,7 @@ impl PubSub {
     }
 
     pub async fn subscribe(&self, topic: &str) -> broadcast::Receiver<Message> {
-        let (tx, _rx) = broadcast::channel(256); // 256 is the channel capacity
+        let (tx, _rx) = broadcast::channel(20_000); // 20000 is the channel capacity
         let mut subscribers = self.subscribers.lock().await;
         subscribers
             .entry(topic.to_string())