diff --git a/applications/tari_validator_node/src/comms/initializer.rs b/applications/tari_validator_node/src/comms/initializer.rs index b62109bf91..1c986ff270 100644 --- a/applications/tari_validator_node/src/comms/initializer.rs +++ b/applications/tari_validator_node/src/comms/initializer.rs @@ -168,8 +168,8 @@ fn configure_comms( .layer(DanBroadcast::new(connectivity, logger1)) .service(sink) }) - .max_concurrent_inbound_tasks(3) - .max_concurrent_outbound_tasks(3) + .max_concurrent_inbound_tasks(1) + .max_concurrent_outbound_tasks(1) .with_inbound_pipeline( ServiceBuilder::new() .layer(DanDeserialize::new(comms.peer_manager(), logger2))