mohr/nexosim
1
0
Fork 0
forked from ROMEO/nexosim
Code Pull Requests Activity

auto-fix clippy::let_and_return

Browse Source
This commit is contained in:
Ben-PH 2025-01-22 14:44:24 +01:00
parent 1b3966b5ae
commit 38f3b82143
3 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
nexosim/src/executor/task/tests/general.rs
View File

@ -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,
(),
);

3
nexosim/src/ports/output/broadcaster.rs
View File

@ -672,9 +672,8 @@ mod tests {
let th_broadcast = thread::spawn(move || {
let iter = block_on(broadcaster.broadcast(MESSAGE)).unwrap();
let sum = iter.sum::<usize>();
sum
iter.sum::<usize>()
});
let th_recv: Vec<_> = mailboxes

3
nexosim/src/ports/source/broadcaster.rs
View File

@ -567,9 +567,8 @@ mod tests {
let th_broadcast = thread::spawn(move || {
let iter = block_on(broadcaster.broadcast(MESSAGE)).unwrap();
let sum = iter.sum::<usize>();
sum
iter.sum::<usize>()
});
let th_recv: Vec<_> = mailboxes