more cleanup

eclipse-zenoh · Apr 1, 2024 · 23931f9 · 23931f9
1 parent 4d0f6e5
commit 23931f9
Show file tree

Hide file tree

Showing 6 changed files with 11 additions and 4 deletions.
diff --git a/plugins/zenoh-plugin-rest/src/lib.rs b/plugins/zenoh-plugin-rest/src/lib.rs
@@ -34,7 +34,6 @@ use zenoh::plugins::{RunningPluginTrait, ZenohPlugin};
 use zenoh::prelude::r#async::*;
 use zenoh::query::{QueryConsolidation, Reply};
 use zenoh::runtime::Runtime;
-use zenoh::sample::builder::ValueBuilderTrait;
 use zenoh::selector::TIME_RANGE_KEY;
 use zenoh::Session;
 use zenoh_plugin_trait::{plugin_long_version, plugin_version, Plugin, PluginControl};

diff --git a/zenoh/src/query.rs b/zenoh/src/query.rs
@@ -15,7 +15,6 @@
 //! Query primitives.
 use crate::handlers::{locked, Callback, DefaultHandler};
 use crate::prelude::*;
-use crate::sample::builder::{QoSBuilderTrait, SampleBuilderTrait, ValueBuilderTrait};
 #[zenoh_macros::unstable]
 use crate::sample::Attachment;
 use crate::sample::QoSBuilder;

diff --git a/zenoh/src/sample/builder.rs b/zenoh/src/sample/builder.rs
@@ -14,9 +14,11 @@
 
 use std::marker::PhantomData;
 
+#[cfg(feature = "unstable")]
 use crate::sample::Attachment;
 use crate::sample::QoS;
 use crate::sample::QoSBuilder;
+#[cfg(feature = "unstable")]
 use crate::sample::SourceInfo;
 use crate::Encoding;
 use crate::KeyExpr;

diff --git a/zenoh/src/sample/mod.rs b/zenoh/src/sample/mod.rs
@@ -117,7 +117,12 @@ impl DataInfoIntoSample for Option<DataInfo> {
         IntoPayload: Into<Payload>,
     {
         if let Some(data_info) = self {
-            data_info.into_sample(key_expr, payload, attachment)
+            data_info.into_sample(
+                key_expr,
+                payload,
+                #[cfg(feature = "unstable")]
+                attachment,
+            )
         } else {
             Sample {
                 key_expr: key_expr.into(),
@@ -172,6 +177,7 @@ impl SourceInfo {
     }
 }
 
+#[zenoh_macros::unstable]
 impl From<SourceInfo> for Option<zenoh::put::ext::SourceInfoType> {
     fn from(source_info: SourceInfo) -> Option<zenoh::put::ext::SourceInfoType> {
         if source_info.is_empty() {

diff --git a/zenoh/src/session.rs b/zenoh/src/session.rs
@@ -809,6 +809,7 @@ impl Session {
             #[cfg(feature = "unstable")]
             attachment: None,
             handler: DefaultHandler,
+            #[cfg(feature = "unstable")]
             source_info: SourceInfo::empty(),
         }
     }

diff --git a/zenoh/tests/attachments.rs b/zenoh/tests/attachments.rs
@@ -14,7 +14,7 @@
 #[cfg(feature = "unstable")]
 #[test]
 fn pubsub() {
-    use zenoh::{prelude::sync::*, sample::builder::SampleBuilderTrait};
+    use zenoh::prelude::sync::*;
 
     let zenoh = zenoh::open(Config::default()).res().unwrap();
     let _sub = zenoh