Bump channel size

planetary-social · Sep 24, 2024 · bef326d · bef326d
1 parent ff968d0
commit bef326d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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);
                                     }