diff options
Diffstat (limited to 'tokio-signal/tests/drop_multi_loop.rs')
| -rw-r--r-- | tokio-signal/tests/drop_multi_loop.rs | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/tokio-signal/tests/drop_multi_loop.rs b/tokio-signal/tests/drop_multi_loop.rs index 62d8da53..7228281f 100644 --- a/tokio-signal/tests/drop_multi_loop.rs +++ b/tokio-signal/tests/drop_multi_loop.rs @@ -10,14 +10,12 @@ const TEST_SIGNAL: libc::c_int = libc::SIGUSR1; #[test] fn dropping_loops_does_not_cause_starvation() { let (mut rt, signal) = { - let mut first_rt = CurrentThreadRuntime::new() - .expect("failed to init first runtime"); + let mut first_rt = CurrentThreadRuntime::new().expect("failed to init first runtime"); let first_signal = run_with_timeout(&mut first_rt, Signal::new(TEST_SIGNAL)) .expect("failed to register first signal"); - let mut second_rt = CurrentThreadRuntime::new() - .expect("failed to init second runtime"); + let mut second_rt = CurrentThreadRuntime::new().expect("failed to init second runtime"); let second_signal = run_with_timeout(&mut second_rt, Signal::new(TEST_SIGNAL)) .expect("failed to register second signal"); @@ -30,10 +28,7 @@ fn dropping_loops_does_not_cause_starvation() { send_signal(TEST_SIGNAL); - let signal_future = signal.into_future() - .map_err(|(e, _)| e); + let signal_future = signal.into_future().map_err(|(e, _)| e); - run_with_timeout(&mut rt, signal_future) - .expect("failed to get signal"); + run_with_timeout(&mut rt, signal_future).expect("failed to get signal"); } - |