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?)),