fix: /subscriptions might return empty list

bytebeamio · Aug 12, 2024 · ebecd75 · ebecd75
1 parent 90b9055
commit ebecd75
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/uplink/src/collector/bus/mod.rs b/uplink/src/collector/bus/mod.rs
@@ -89,7 +89,7 @@ impl BusTx {
         let body = get(url).await?.bytes().await?;
         let subscriptions: HashMap<String, Vec<String>> = serde_json::from_slice(&body)?;
 
-        if !subscriptions.contains_key(&topic) {
+        if subscriptions.get(&topic).is_some_and(|s| !s.is_empty()) {
             return Err(Error::NoRoute);
         }