@clux's feedback

Co-authored-by: Eirik A <[email protected]> Signed-off-by: Matei David <[email protected]>
kube-rs · Apr 3, 2024 · 21dbbae · 21dbbae
1 parent d69213a
commit 21dbbae
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/examples/shared_stream_controllers.rs b/examples/shared_stream_controllers.rs
@@ -147,7 +147,7 @@ async fn reconcile_metadata(pod: Arc<Pod>, ctx: Arc<Data>) -> Result<Action, Err
     if pod.name_any() == "kube-system" {
         return Ok(Action::requeue(Duration::from_secs(300)));
     }
-    let labels = pod.metadata.labels.clone().unwrap_or_else(|| Default::default());
+    let labels = pod.metadata.labels();
     if labels.len() == 0 {
         return Ok(Action::requeue(Duration::from_secs(180)));
     }

diff --git a/kube-runtime/src/utils/watch_ext.rs b/kube-runtime/src/utils/watch_ext.rs
@@ -249,7 +249,7 @@ pub trait WatchStreamExt: Stream {
         Reflect::new(self, writer)
     }
 
-    fn reflect_dispatch<K>(self, writer: Writer<K>) -> impl Stream<Item = Self::Item>
+    fn reflect_shared<K>(self, writer: Writer<K>) -> impl Stream<Item = Self::Item>
     where
         Self: Stream<Item = watcher::Result<watcher::Event<K>>> + Sized,
         K: Resource + Clone + 'static,