mirror of
https://framagit.org/ppom/reaction
synced 2026-03-14 12:45:47 +01:00
cargo fmt
This commit is contained in:
parent
a7b63b69a8
commit
e8f13dc9ff
2 changed files with 4 additions and 14 deletions
|
|
@ -119,10 +119,7 @@ fn handle_show_or_flush_order(
|
|||
.iter()
|
||||
// stream filtering
|
||||
.filter(|(stream, _)| {
|
||||
stream_name.is_none()
|
||||
|| stream_name
|
||||
.clone()
|
||||
.is_some_and(|name| name == stream.name)
|
||||
stream_name.is_none() || stream_name.clone().is_some_and(|name| name == stream.name)
|
||||
})
|
||||
.fold(BTreeMap::new(), |mut acc, (stream, filter_manager)| {
|
||||
let inner_map = filter_manager
|
||||
|
|
@ -130,9 +127,7 @@ fn handle_show_or_flush_order(
|
|||
// filter filtering
|
||||
.filter(|(filter, _)| {
|
||||
filter_name.is_none()
|
||||
|| filter_name
|
||||
.clone()
|
||||
.is_some_and(|name| name == filter.name)
|
||||
|| filter_name.clone().is_some_and(|name| name == filter.name)
|
||||
})
|
||||
// pattern filtering
|
||||
.filter(|(filter, _)| {
|
||||
|
|
|
|||
|
|
@ -90,11 +90,7 @@ impl StreamManager {
|
|||
{
|
||||
Ok(child) => child,
|
||||
Err(err) => {
|
||||
error!(
|
||||
"could not execute stream {} cmd: {}",
|
||||
self.stream.name,
|
||||
err
|
||||
);
|
||||
error!("could not execute stream {} cmd: {}", self.stream.name, err);
|
||||
return;
|
||||
}
|
||||
};
|
||||
|
|
@ -183,8 +179,7 @@ impl StreamManager {
|
|||
Some(Err(err)) => {
|
||||
error!(
|
||||
"impossible to read output from stream {}: {}",
|
||||
self.stream.name,
|
||||
err
|
||||
self.stream.name, err
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue