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

auto-fix clippy::uneccesary_fold

Browse Source
This commit is contained in:
Ben-PH 2025-01-22 14:42:13 +01:00
parent c75d92145e
commit 1b3966b5ae
2 changed files with 8 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -672,7 +672,7 @@ mod tests {
let th_broadcast = thread::spawn(move || {
let iter = block_on(broadcaster.broadcast(MESSAGE)).unwrap();
let sum = iter.fold(0, |acc, val| acc + val);
let sum = iter.sum::<usize>();
sum
});
@ -727,11 +727,7 @@ mod tests {
// Send messages reaching only one receiver each.
for id in 0..N_RECV {
sum += broadcaster
.broadcast(id)
.await
.unwrap()
.fold(0, |acc, val| acc + val);
sum += broadcaster.broadcast(id).await.unwrap().sum::<usize>();
}
// Broadcast the special value to all receivers.
@ -739,15 +735,11 @@ mod tests {
.broadcast(BROADCAST_ALL)
.await
.unwrap()
.fold(0, |acc, val| acc + val);
.sum::<usize>();
// Send again messages reaching only one receiver each.
for id in 0..N_RECV {
sum += broadcaster
.broadcast(id)
.await
.unwrap()
.fold(0, |acc, val| acc + val);
sum += broadcaster.broadcast(id).await.unwrap().sum::<usize>();
}
sum

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

@ -567,7 +567,7 @@ mod tests {
let th_broadcast = thread::spawn(move || {
let iter = block_on(broadcaster.broadcast(MESSAGE)).unwrap();
let sum = iter.fold(0, |acc, val| acc + val);
let sum = iter.sum::<usize>();
sum
});
@ -622,11 +622,7 @@ mod tests {
// Send messages reaching only one receiver each.
for id in 0..N_RECV {
sum += broadcaster
.broadcast(id)
.await
.unwrap()
.fold(0, |acc, val| acc + val);
sum += broadcaster.broadcast(id).await.unwrap().sum::<usize>();
}
// Broadcast the special value to all receivers.
@ -634,15 +630,11 @@ mod tests {
.broadcast(BROADCAST_ALL)
.await
.unwrap()
.fold(0, |acc, val| acc + val);
.sum::<usize>();
// Send again messages reaching only one receiver each.
for id in 0..N_RECV {
sum += broadcaster
.broadcast(id)
.await
.unwrap()
.fold(0, |acc, val| acc + val);
sum += broadcaster.broadcast(id).await.unwrap().sum::<usize>();
}
sum