Also move the subscriber into a separate task, otherwise it will never run since the reflector looping forever

Signed-off-by: Natalie Klestrup Röijezon <[email protected]>

Author: nightkr

kube-runtime/src/utils/watch_ext.rs

@@ -238,6 +238,13 @@ pub trait WatchStreamExt: Stream {
     ///     }
     /// });
     ///
+    /// tokio::spawn(async move {
+    ///     // subscriber can be used to receive applied_objects
+    ///     subscriber.for_each(|obj| async move {
+    ///         info!("saw in subscriber {}", &obj.name_any())
+    ///     }).await;
+    /// });
+    ///
     /// // configure the watcher stream and populate the store while polling
     /// watcher(deploys, watcher::Config::default())
     ///     .reflect_shared(writer)
@@ -250,11 +257,6 @@ pub trait WatchStreamExt: Stream {
     ///     })
     ///     .await;
     ///
-    /// // subscriber can be used to receive applied_objects
-    /// subscriber.for_each(|obj| async move {
-    ///     info!("saw in subscriber {}", &obj.name_any())
-    /// }).await;
-    ///
     /// # Ok(())
     /// # }
     /// ```