main: Increase the broadcast channel capacity

This commit is contained in:
mirsal 2024-11-25 04:06:01 +00:00
parent 148d4e7e43
commit b93f921bcb
Signed by: mirsal
GPG Key ID: F78F9FE84AE5B610

View File

@ -51,7 +51,7 @@ async fn main() -> anyhow::Result<()> {
// This message passing channel is used for sending messages to the matrix module, // This message passing channel is used for sending messages to the matrix module,
// it holds a tuple with an HTML message and a list of rooms to post to // it holds a tuple with an HTML message and a list of rooms to post to
let (bcast_tx, bcast_rx) = broadcast::channel(16); let (bcast_tx, bcast_rx) = broadcast::channel(1024);
let state_db = FeedReaderStateDb::new("state.yaml").await let state_db = FeedReaderStateDb::new("state.yaml").await
.expect("Failed to initialize feed reader state db"); .expect("Failed to initialize feed reader state db");