From 21dbbae8996ec9d5aa4b0e6a5bd3fdaef1564a7f Mon Sep 17 00:00:00 2001
From: Matei David <matei.david.35@gmail.com>
Date: Wed, 3 Apr 2024 19:02:50 +0100
Subject: [PATCH] @clux's feedback

Co-authored-by: Eirik A <sszynrae@gmail.com>
Signed-off-by: Matei David <matei.david.35@gmail.com>
---
 examples/shared_stream_controllers.rs | 2 +-
 kube-runtime/src/utils/watch_ext.rs   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/examples/shared_stream_controllers.rs b/examples/shared_stream_controllers.rs
index 0e2e3f2cd..0cbbb0de3 100644
--- 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
index 8a1f4fc20..d5d2b4a92 100644
--- 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,