From 75d3cddb68da31f195aed5038ed6a1bbce99b90d Mon Sep 17 00:00:00 2001 From: tottoto Date: Sat, 6 Apr 2024 01:18:14 +0900 Subject: [PATCH] Move pin value in examples to independent sentence Signed-off-by: tottoto --- examples/event_watcher.rs | 3 ++- examples/node_reflector.rs | 5 +++-- examples/node_watcher.rs | 3 ++- examples/pod_reflector.rs | 5 +++-- 4 files changed, 10 insertions(+), 6 deletions(-) diff --git a/examples/event_watcher.rs b/examples/event_watcher.rs index 916f320d6..d05de1188 100644 --- a/examples/event_watcher.rs +++ b/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? { diff --git a/examples/node_reflector.rs b/examples/node_reflector.rs index 317961ddc..4444e5757 100644 --- a/examples/node_reflector.rs +++ b/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 { diff --git a/examples/node_watcher.rs b/examples/node_watcher.rs index 6d8e39250..4ed4c0d2e 100644 --- a/examples/node_watcher.rs +++ b/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?; diff --git a/examples/pod_reflector.rs b/examples/pod_reflector.rs index 290277c51..a93af1b6b 100644 --- a/examples/pod_reflector.rs +++ b/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());