mirror of
https://github.com/hl-archive-node/nanoreth.git
synced 2025-12-06 10:59:55 +00:00
chore: fix flaky test (#4729)
This commit is contained in:
@ -568,9 +568,10 @@ async fn test_disconnect_incoming_when_exceeded_incoming_connections() {
|
|||||||
|
|
||||||
let config = NetworkConfigBuilder::new(secret_key)
|
let config = NetworkConfigBuilder::new(secret_key)
|
||||||
.listener_port(0)
|
.listener_port(0)
|
||||||
.discovery_port(0)
|
.disable_discovery()
|
||||||
.peer_config(peers_config)
|
.peer_config(peers_config)
|
||||||
.build(NoopProvider::default());
|
.build(NoopProvider::default());
|
||||||
|
|
||||||
let network = NetworkManager::new(config).await.unwrap();
|
let network = NetworkManager::new(config).await.unwrap();
|
||||||
|
|
||||||
let other_peer_handle = net.handles().next().unwrap();
|
let other_peer_handle = net.handles().next().unwrap();
|
||||||
@ -580,9 +581,11 @@ async fn test_disconnect_incoming_when_exceeded_incoming_connections() {
|
|||||||
other_peer_handle.add_peer(*handle.peer_id(), handle.local_addr());
|
other_peer_handle.add_peer(*handle.peer_id(), handle.local_addr());
|
||||||
|
|
||||||
tokio::task::spawn(network);
|
tokio::task::spawn(network);
|
||||||
let _handle = net.spawn();
|
let net_handle = net.spawn();
|
||||||
|
|
||||||
tokio::time::sleep(Duration::from_secs(1)).await;
|
tokio::time::sleep(Duration::from_secs(1)).await;
|
||||||
|
|
||||||
assert_eq!(handle.num_connected_peers(), 0);
|
assert_eq!(handle.num_connected_peers(), 0);
|
||||||
|
|
||||||
|
net_handle.terminate().await;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user