fix: fix typo

eclipse-zenoh · Dec 11, 2024 · 867a552 · 867a552
1 parent 0bef330
commit 867a552
Showing 1 changed file with 31 additions and 31 deletions.
diff --git a/zenoh/src/net/routing/dispatcher/pubsub.rs b/zenoh/src/net/routing/dispatcher/pubsub.rs
@@ -456,38 +456,38 @@ pub fn route_data(
                         reliability,
                     );
                     routed = true;
-                } else {
-                    let route = route
-                        .values()
-                        .filter(|(outface, _key_expr, _context)| {
-                            tables
-                                .hat_code
-                                .egress_filter(&tables, face, outface, &mut expr)
-                        })
-                        .cloned()
-                        .collect::<Vec<Direction>>();
-
-                    drop(tables);
-                    for (outface, key_expr, context) in route {
-                        #[cfg(feature = "stats")]
-                        if !admin {
-                            inc_stats!(face, tx, user, msg.payload)
-                        } else {
-                            inc_stats!(face, tx, admin, msg.payload)
-                        }
-
-                        outface.primitives.send_push(
-                            Push {
-                                wire_expr: key_expr,
-                                ext_qos: msg.ext_qos,
-                                ext_tstamp: None,
-                                ext_nodeid: ext::NodeIdType { node_id: context },
-                                payload: msg.payload.clone(),
-                            },
-                            reliability,
-                        );
-                        routed = true;
+                }
+            } else {
+                let route = route
+                    .values()
+                    .filter(|(outface, _key_expr, _context)| {
+                        tables
+                            .hat_code
+                            .egress_filter(&tables, face, outface, &mut expr)
+                    })
+                    .cloned()
+                    .collect::<Vec<Direction>>();
+
+                drop(tables);
+                for (outface, key_expr, context) in route {
+                    #[cfg(feature = "stats")]
+                    if !admin {
+                        inc_stats!(face, tx, user, msg.payload)
+                    } else {
+                        inc_stats!(face, tx, admin, msg.payload)
                     }
+
+                    outface.primitives.send_push(
+                        Push {
+                            wire_expr: key_expr,
+                            ext_qos: msg.ext_qos,
+                            ext_tstamp: None,
+                            ext_nodeid: ext::NodeIdType { node_id: context },
+                            payload: msg.payload.clone(),
+                        },
+                        reliability,
+                    );
+                    routed = true;
                 }
             }
         }