From bef326d0e2133f5747477dcf4c54bcef31d807b1 Mon Sep 17 00:00:00 2001
From: Daniel Cadenas <dcadenas@gmail.com>
Date: Tue, 24 Sep 2024 11:58:11 -0300
Subject: [PATCH] Bump channel size

---
 src/publisher.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/publisher.rs b/src/publisher.rs
index 61e2106..a6cff36 100644
--- a/src/publisher.rs
+++ b/src/publisher.rs
@@ -43,7 +43,8 @@ impl Publisher {
         flush_period_seconds: NonZeroUsize,
         min_seconds_between_messages: NonZeroUsize,
     ) -> Result<Self, PublisherError> {
-        let (publication_sender, mut publication_receiver) = mpsc::channel::<Box<FollowChange>>(1);
+        let (publication_sender, mut publication_receiver) =
+            mpsc::channel::<Box<FollowChange>>(2000);
 
         let mut buffer = NotificationFactory::new(min_seconds_between_messages);
         tokio::spawn(async move {
@@ -68,7 +69,7 @@ impl Publisher {
 
                             if let Err(e) = client.publish_events(buffer.flush()).await {
                                 match &e {
-                                    // We've seen this happen sporadically, we don't neet to kill the look in this situation
+                                    // We've seen this happen sporadically, we don't neet to kill the loop in this situation
                                     PublisherError::PublishError => {
                                         error!("{}", e);
                                     }