diff options
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/src/main.rs b/src/main.rs index 266e915..bc9a7b5 100644 --- a/src/main.rs +++ b/src/main.rs @@ -79,17 +79,18 @@ async fn main() -> anyhow::Result<()> { match notification? { Incoming(Packet::Publish(p)) => { for (topic, programs) in conf.routes.iter() { - if topic_match(&topic, &p.topic) { - for program in programs { - // TODO: Switch to moro_local to avoid this ewwyness - let program = program.clone(); - let p = p.clone(); - tokio::spawn(async move { - if let Err(e) = run(&program, &p).await { - eprintln!("error: Failed to run {program:?}: {e:?}"); - } - }); - } + if !topic_match(&topic, &p.topic) { + continue; + } + for program in programs { + // TODO: Switch to moro_local to avoid this ewwyness + let program = program.clone(); + let p = p.clone(); + tokio::spawn(async move { + if let Err(e) = run(&program, &p).await { + eprintln!("error: Failed to run {program:?}: {e:?}"); + } + }); } } } |