fix: raise the buffer size for subscribe responses

eqlabs · Mar 25, 2020 · ac08a63 · ac08a63
1 parent 090a3ee
commit ac08a63
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/http/src/v0/pubsub.rs b/http/src/v0/pubsub.rs
@@ -165,8 +165,8 @@ async fn inner_subscribe<T: IpfsTypes>(
 
             // 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::<Result<PreformattedJsonMessage, StreamError>>(4);
+            // multiple subscriptions and unsubscriptions.
+            let (tx, rx) = broadcast::channel::<Result<PreformattedJsonMessage, StreamError>>(16);
 
             // this will be used to create more subscriptions
             ve.insert(tx.clone());