Making slot channel unbounded (bug)

blockworks-foundation · Jan 17, 2024 · c923f3a · c923f3a
1 parent f77a89e
commit c923f3a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cluster-endpoints/src/grpc_multiplex.rs b/cluster-endpoints/src/grpc_multiplex.rs
@@ -235,7 +235,7 @@ pub fn create_grpc_multiplex_slots_subscription(
             let mut streams_tasks = Vec::new();
             let mut recievers = Vec::new();
             for grpc_source in &grpc_sources {
-                let (sx, rx) = async_channel::bounded(1);
+                let (sx, rx) = async_channel::unbounded();
                 let task = create_slot_stream_task(
                     grpc_source.grpc_addr.clone(),
                     grpc_source.grpc_x_token.clone(),