diff --git a/tests/simulator/src/local_network.rs b/tests/simulator/src/local_network.rs index c659b2f65..ad01eaf25 100644 --- a/tests/simulator/src/local_network.rs +++ b/tests/simulator/src/local_network.rs @@ -94,7 +94,7 @@ impl LocalNetwork { .expect("bootnode must have a network"), ); }) - .expect("should have atleast one node"); + .expect("should have at least one node"); let index = self.beacon_nodes.read().len(); diff --git a/tests/simulator/src/sync_sim.rs b/tests/simulator/src/sync_sim.rs index 6c18406b6..13fa61d04 100644 --- a/tests/simulator/src/sync_sim.rs +++ b/tests/simulator/src/sync_sim.rs @@ -94,8 +94,10 @@ pub fn verify_two_nodes_sync( // Add beacon nodes network .add_beacon_node(beacon_config.clone()) - .join(network.add_beacon_node(beacon_config.clone())) - .map(|_| network) + .map(|_| (network, beacon_config)) + .and_then(|(network, beacon_config)| { + network.add_beacon_node(beacon_config).map(|_| network) + }) }) .and_then(move |network| { // Delay for `sync_delay` epochs before verifying synced state. @@ -128,8 +130,10 @@ pub fn verify_in_between_sync( // Add a beacon node network .add_beacon_node(beacon_config.clone()) - .join(network.add_beacon_node(beacon_config.clone())) - .map(|_| network) + .map(|_| (network, beacon_config)) + .and_then(|(network, beacon_config)| { + network.add_beacon_node(beacon_config).map(|_| network) + }) }) .and_then(move |network| { // Delay before adding additional syncing nodes.