diff --git a/mysticeti-core/src/simulated_network.rs b/mysticeti-core/src/simulated_network.rs index 85bbe1c9..eaa22a89 100644 --- a/mysticeti-core/src/simulated_network.rs +++ b/mysticeti-core/src/simulated_network.rs @@ -55,6 +55,7 @@ impl SimulatedNetwork { pub async fn connect(&self, a: usize, b: usize) { let (a_sender, a_receiver) = Self::latency_channel(); let (b_sender, b_receiver) = Self::latency_channel(); + // the watch channels are responsible for disseminating the calculated latency for each connection. let (_al_sender, al_receiver) = tokio::sync::watch::channel(Duration::from_secs(0)); let (_bl_sender, bl_receiver) = tokio::sync::watch::channel(Duration::from_secs(0)); let a_connection = Connection {