Sync lockfile with Zenoh 3740564 from 2024-10-08 (#359)

eclipse-zenoh · Oct 8, 2024 · 196629e · 196629e
1 parent 36a6702
commit 196629e
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 29 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/zenoh-plugin-dds/src/lib.rs b/zenoh-plugin-dds/src/lib.rs
@@ -40,6 +40,7 @@ use tokio::task::JoinHandle;
 use tracing::{debug, error, info, trace, warn};
 use zenoh::{
     bytes::{Encoding, ZBytes},
+    handlers::FifoChannelHandler,
     internal::{
         plugins::{RunningPlugin, RunningPluginTrait, ZenohPlugin},
         runtime::Runtime,
@@ -783,7 +784,7 @@ impl<'a> DdsPluginRuntime<'a> {
         group_subscriber: &Receiver<Sample>,
         dds_disco_rcv: &Receiver<DiscoveryEvent>,
         admin_keyexpr_prefix: OwnedKeyExpr,
-        admin_queryable: &Queryable<flume::Receiver<Query>>,
+        admin_queryable: &Queryable<FifoChannelHandler<Query>>,
     ) {
         debug!(r#"Run in "local discovery" mode"#);
 
@@ -976,7 +977,7 @@ impl<'a> DdsPluginRuntime<'a> {
         group_subscriber: &Receiver<Sample>,
         dds_disco_rcv: &Receiver<DiscoveryEvent>,
         admin_keyexpr_prefix: OwnedKeyExpr,
-        admin_queryable: &Queryable<flume::Receiver<Query>>,
+        admin_queryable: &Queryable<FifoChannelHandler<Query>>,
     ) {
         debug!(r#"Run in "forward discovery" mode"#);