diff --git a/kube-runtime/src/utils/mod.rs b/kube-runtime/src/utils/mod.rs index beae8a5b2..90d84524e 100644 --- a/kube-runtime/src/utils/mod.rs +++ b/kube-runtime/src/utils/mod.rs @@ -10,7 +10,6 @@ pub use event_flatten::EventFlatten; pub use stream_backoff::StreamBackoff; pub use watch_ext::WatchStreamExt; -use crate::watcher; use futures::{ pin_mut, stream::{self, Peekable}, @@ -26,31 +25,6 @@ use std::{ use stream::IntoStream; use tokio::{runtime::Handle, task::JoinHandle}; -/// Flattens each item in the list following the rules of [`watcher::Event::into_iter_applied`]. -#[deprecated( - since = "0.72.0", - note = "fn replaced with the WatchStreamExt::applied_objects which can be chained onto watcher. Add `use kube::runtime::WatchStreamExt;` and call `stream.applied_objects()` instead. This function will be removed in 0.75.0." -)] -pub fn try_flatten_applied>>( - stream: S, -) -> impl Stream> { - stream - .map_ok(|event| stream::iter(event.into_iter_applied().map(Ok))) - .try_flatten() -} - -/// Flattens each item in the list following the rules of [`watcher::Event::into_iter_touched`]. -#[deprecated( - since = "0.72.0", - note = "fn replaced with the WatchStreamExt::touched_objects which can be chained onto watcher. Add `use kube::runtime::WatchStreamExt;` and call `stream.touched_objects()` instead. This function will be removed in 0.75.0." -)] -pub fn try_flatten_touched>>( - stream: S, -) -> impl Stream> { - stream - .map_ok(|event| stream::iter(event.into_iter_touched().map(Ok))) - .try_flatten() -} /// Allows splitting a `Stream` into several streams that each emit a disjoint subset of the input stream's items, /// like a streaming variant of pattern matching.