Move pin value in examples to independent sentence

Signed-off-by: tottoto <[email protected]>

examples/event_watcher.rs

@@ -38,7 +38,8 @@ async fn main() -> anyhow::Result<()> {
             conf = conf.fields(&format!("regarding.kind={kind},regarding.name={name}"));
         }
     }
-    let mut event_stream = pin!(watcher(events, conf).default_backoff().applied_objects());
+    let event_stream = watcher(events, conf).default_backoff().applied_objects();
+    let mut event_stream = pin!(event_stream);
 
     println!("{0:<6} {1:<15} {2:<55} {3}", "AGE", "REASON", "OBJECT", "MESSAGE");
     while let Some(ev) = event_stream.try_next().await? {

examples/node_reflector.rs

@@ -20,11 +20,12 @@ async fn main() -> anyhow::Result<()> {
         .timeout(10); // short watch timeout in this example
 
     let (reader, writer) = reflector::store();
-    let mut stream = pin!(watcher(nodes, wc)
+    let stream = watcher(nodes, wc)
         .default_backoff()
         .reflect(writer)
         .applied_objects()
-        .predicate_filter(predicates::labels.combine(predicates::annotations))); // NB: requires an unstable feature
+        .predicate_filter(predicates::labels.combine(predicates::annotations)); // NB: requires an unstable feature
+    let mut stream = pin!(stream);
 
     // Periodically read our state in the background
     tokio::spawn(async move {

examples/node_watcher.rs

@@ -22,7 +22,8 @@ async fn main() -> anyhow::Result<()> {
     } else {
         watcher::Config::default()
     };
-    let mut obs = pin!(watcher(nodes, wc).default_backoff().applied_objects());
+    let obs = watcher(nodes, wc).default_backoff().applied_objects();
+    let mut obs = pin!(obs);
 
     while let Some(n) = obs.try_next().await? {
         check_for_node_failures(&client, n).await?;

examples/pod_reflector.rs

@@ -31,7 +31,7 @@ async fn main() -> anyhow::Result<()> {
         }
     });
 
-    let mut stream = pin!(watcher(api, watcher::Config::default().any_semantic())
+    let stream = watcher(api, watcher::Config::default().any_semantic())
         .default_backoff()
         .modify(|pod| {
             // memory optimization for our store - we don't care about managed fields/annotations/status
@@ -41,7 +41,8 @@ async fn main() -> anyhow::Result<()> {
         })
         .reflect(writer)
         .applied_objects()
-        .predicate_filter(predicates::resource_version)); // NB: requires an unstable feature
+        .predicate_filter(predicates::resource_version); // NB: requires an unstable feature
+    let mut stream = pin!(stream);
 
     while let Some(pod) = stream.try_next().await? {
         info!("saw {}", pod.name_any());