move delay timer and make it happen early

This commit is contained in:
fakeshadow 2021-04-12 04:26:48 +08:00
parent 0d77e0076c
commit f13d76c67d
1 changed files with 2 additions and 0 deletions

View File

@ -540,6 +540,8 @@ async fn test_worker_restart() {
assert_eq!("1", id); assert_eq!("1", id);
stream.shutdown().await.unwrap(); stream.shutdown().await.unwrap();
sleep(Duration::from_secs(5)).await;
// worker 2 restarting and work goes to worker 1. // worker 2 restarting and work goes to worker 1.
let mut stream = TcpStream::connect(addr).await.unwrap(); let mut stream = TcpStream::connect(addr).await.unwrap();