diff --git a/http/src/v0/pubsub.rs b/http/src/v0/pubsub.rs index a7f051dc7..65607364e 100644 --- a/http/src/v0/pubsub.rs +++ b/http/src/v0/pubsub.rs @@ -165,8 +165,8 @@ async fn inner_subscribe( // using broadcast channel should allow us have N concurrent subscribes and // preformatted json should give us good enough performance. this channel can last over - // multiple subscriptions and unsubscriptions - let (tx, rx) = broadcast::channel::>(4); + // multiple subscriptions and unsubscriptions. + let (tx, rx) = broadcast::channel::>(16); // this will be used to create more subscriptions ve.insert(tx.clone());