Put StreamSubscribe behind a feature flag unstable_runtime_subscribe

kube-rs · Feb 17, 2023 · 70c6ccb · 70c6ccb
1 parent ec5cdc0
commit 70c6ccb
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/kube-runtime/Cargo.toml b/kube-runtime/Cargo.toml
@@ -14,6 +14,10 @@ categories = ["web-programming::http-client", "caching", "network-programming"]
 rust-version = "1.60.0"
 edition = "2021"
 
+[features]
+unstable_runtime = ["unstable_runtime_subscribe"]
+unstable_runtime_subscribe = []
+
 [package.metadata.docs.rs]
 features = ["k8s-openapi/v1_26"]
 # Define the configuration attribute `docsrs`. Used to enable `doc_cfg` feature.

diff --git a/kube-runtime/src/utils/mod.rs b/kube-runtime/src/utils/mod.rs
@@ -9,6 +9,7 @@ mod watch_ext;
 pub use backoff_reset_timer::ResetTimerBackoff;
 pub use event_flatten::EventFlatten;
 pub use stream_backoff::StreamBackoff;
+#[cfg(feature = "unstable_runtime_subscribe")]
 pub use stream_subscribe::StreamSubscribe;
 pub use watch_ext::WatchStreamExt;
 

diff --git a/kube-runtime/src/utils/watch_ext.rs b/kube-runtime/src/utils/watch_ext.rs
@@ -93,6 +93,7 @@ pub trait WatchStreamExt: Stream {
     ///     (stream_subscribe, explain_stream)
     /// }
     /// ```
+    #[cfg(feature = "unstable_runtime_subscribe")]
     fn stream_subscribe<K>(self) -> StreamSubscribe<Self>
     where
         Self: Stream<Item = Result<watcher::Event<K>, watcher::Error>> + Send + Sized + 'static,