configurable channel capacity

Author: keyvankhademi

lazer/sdk/rust/client/examples/subscribe_price_feeds.rs

@@ -45,7 +45,11 @@ async fn main() -> anyhow::Result<()> {
             .build(),
     )?;
 
-    let stream = client.start().await?;
+    let stream = client
+        .start(
+            1000, // Use a channel capacity of 1000
+        )
+        .await?;
     pin!(stream);
 
     let subscription_requests = vec![

lazer/sdk/rust/client/src/client.rs

@@ -55,8 +55,8 @@ impl PythLazerClient {
         })
     }
 
-    pub async fn start(&mut self) -> Result<mpsc::Receiver<AnyResponse>> {
-        let (sender, receiver) = mpsc::channel::<AnyResponse>(CHANNEL_CAPACITY);
+    pub async fn start(&mut self, channel_capacity: usize) -> Result<mpsc::Receiver<AnyResponse>> {
+        let (sender, receiver) = mpsc::channel::<AnyResponse>(channel_capacity);
 
         for i in 0..self.num_connections {
             let endpoint = self.endpoints[i % self.endpoints.len()].clone();