From b5cf9f28bafdde19b95640d46b6e083d356cc988 Mon Sep 17 00:00:00 2001 From: Aiden McClelland Date: Tue, 15 Jun 2021 13:09:46 -0600 Subject: [PATCH] increase subscriber channel size --- patch-db/src/store.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/patch-db/src/store.rs b/patch-db/src/store.rs index 82ce6f0..0cbe6a6 100644 --- a/patch-db/src/store.rs +++ b/patch-db/src/store.rs @@ -206,7 +206,7 @@ pub struct PatchDb { } impl PatchDb { pub async fn open>(path: P) -> Result { - let (subscriber, _) = tokio::sync::broadcast::channel(16); // TODO: make this unbounded + let (subscriber, _) = tokio::sync::broadcast::channel(512); // TODO: make this unbounded Ok(PatchDb { store: Arc::new(RwLock::new(Store::open(path).await?)),