pub fn watch<T>(
        &mut self,
        api: Api<T>,
        params: ListParams,
    ) -> impl Stream<Item = watcher::Event<T>>
    where
        T: Resource + DeserializeOwned + Clone + Debug + Send + 'static,
        T::DynamicType: Default,
    {
        let watch = watcher::watcher(api, params);
        let successful = errors::LogAndSleep::fixed_delay(self.error_delay, watch);
        let initialized = self.initialized.add_handle().release_on_ready(successful);
        shutdown::CancelOnShutdown::new(self.shutdown_rx.clone(), initialized)
    }
/// Creates a watch with the given [`Api`]
///
/// If the underlying stream encounters errors, the request is retried (potentially after a
/// delay).
///
/// The runtime is not considered initialized until the returned stream returns at least one
/// event.
///
/// The return stream terminates when the runtime receives a shutdown signal.
Creates a watch with the given [`Api`]
If the underlying stream encounters errors, the request is retried (potentially after a
delay).

The runtime is not considered initialized until the returned stream returns at least one
event.

The return stream terminates when the runtime receives a shutdown signal.
Creates a watch with the given [ ` Api ` ] If the underlying stream encounters errors the request is retried ( potentially after a delay ) . The runtime is not considered initialized until the returned stream returns at least one event . The return stream terminates when the runtime receives a shutdown signal .
pub fn watch<T>(
        &mut self,
        api: Api<T>,
        params: ListParams,
    ) -> impl Stream<Item = watcher::Event<T>>
    where
        T: Resource + DeserializeOwned + Clone + Debug + Send + 'static,
        T::DynamicType: Default,
    {
        let watch = watcher::watcher(api, params);
        let successful = errors::LogAndSleep::fixed_delay(self.error_delay, watch);
        let initialized = self.initialized.add_handle().release_on_ready(successful);
        shutdown::CancelOnShutdown::new(self.shutdown_rx.clone(), initialized)
    }
pub fn watch < T > ( & mut self , api : Api < T > , params : ListParams , ) -> impl Stream < Item = watcher :: Event < T > > where T : Resource + DeserializeOwned + Clone + Debug + Send + ' static , T :: DynamicType : Default , { let watch = watcher :: watcher ( api , params ) ; let successful = errors :: LogAndSleep :: fixed_delay ( self . error_delay , watch ) ; let initialized = self . initialized . add_handle ( ) . release_on_ready ( successful ) ; shutdown :: CancelOnShutdown :: new ( self . shutdown_rx . clone ( ) , initialized ) }
Creates a watch with the given [`Api`]
If the underlying stream encounters errors, the request is retried (potentially after a
delay).
Creates a watch with the given [ ` Api ` ] If the underlying stream encounters errors the request is retried ( potentially after a delay ) .
&mut self
api
Api<T>
params
ListParams
&mut self
api
Api<T>
params
ListParams