diff --git a/nexosim/src/executor/task/tests/general.rs b/nexosim/src/executor/task/tests/general.rs index 00c42b7..c5d3421 100644 --- a/nexosim/src/executor/task/tests/general.rs +++ b/nexosim/src/executor/task/tests/general.rs @@ -215,10 +215,8 @@ fn task_wake() { let (sender, receiver) = oneshot::channel(); - let (future, future_is_alive, output_is_alive) = MonitoredFuture::new(async move { - let result = receiver.await.unwrap(); - result - }); + let (future, future_is_alive, output_is_alive) = + MonitoredFuture::new(async move { receiver.await.unwrap() }); let (promise, runnable, _cancel_token) = spawn(future, schedule_runnable, ()); runnable.run(); @@ -244,10 +242,7 @@ fn task_wake_mt() { let (sender, receiver) = oneshot::channel(); let (promise, runnable, _cancel_token) = spawn( - async move { - let result = receiver.await.unwrap(); - result - }, + async move { receiver.await.unwrap() }, schedule_runnable, (), ); diff --git a/nexosim/src/ports/output/broadcaster.rs b/nexosim/src/ports/output/broadcaster.rs index ba5f22b..0a2f9a4 100644 --- a/nexosim/src/ports/output/broadcaster.rs +++ b/nexosim/src/ports/output/broadcaster.rs @@ -672,9 +672,8 @@ mod tests { let th_broadcast = thread::spawn(move || { let iter = block_on(broadcaster.broadcast(MESSAGE)).unwrap(); - let sum = iter.sum::(); - sum + iter.sum::() }); let th_recv: Vec<_> = mailboxes diff --git a/nexosim/src/ports/source/broadcaster.rs b/nexosim/src/ports/source/broadcaster.rs index 64c45e7..107b96a 100644 --- a/nexosim/src/ports/source/broadcaster.rs +++ b/nexosim/src/ports/source/broadcaster.rs @@ -567,9 +567,8 @@ mod tests { let th_broadcast = thread::spawn(move || { let iter = block_on(broadcaster.broadcast(MESSAGE)).unwrap(); - let sum = iter.sum::(); - sum + iter.sum::() }); let th_recv: Vec<_> = mailboxes