Skip to content

Commit

Permalink
Fix doctest reference to futures_util
Browse files Browse the repository at this point in the history
Also fix link in controller/mod.rs to futures::stream::select.

Signed-off-by: onalante-msft <[email protected]>
  • Loading branch information
onalante-msft committed May 11, 2022
1 parent d0e1b9f commit 8db2851
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion kube-runtime/src/controller/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -239,7 +239,7 @@ impl Display for ReconcileReason {
///
/// The `queue` indicates which objects should be reconciled. For the core objects this will usually be
/// the [`reflector`] (piped through [`trigger_self`]). If your core objects own any subobjects then you
/// can also make them trigger reconciliations by [merging](`futures::stream::select`) the [`reflector`]
/// can also make them trigger reconciliations by [merging](futures::stream::select) the [`reflector`]
/// with a [`watcher`](watcher()) or [`reflector`](reflector()) for the subobject.
///
/// This is the "hard-mode" version of [`Controller`], which allows you some more customization
Expand Down
2 changes: 1 addition & 1 deletion kube-runtime/src/watcher.rs
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,7 @@ async fn step<K: Resource + Clone + DeserializeOwned + Debug + Send + 'static>(
/// runtime::{utils::try_flatten_applied, watcher}
/// };
/// use k8s_openapi::api::core::v1::Pod;
/// use futures_util::{StreamExt, TryStreamExt};
/// use futures::{StreamExt, TryStreamExt};
/// #[tokio::main]
/// async fn main() -> Result<(), watcher::Error> {
/// let client = Client::try_default().await.unwrap();
Expand Down

0 comments on commit 8db2851

Please sign in to comment.