pub async fn probe(mut self) -> Result<(), anyhow::Error> {
        loop {
            self.probe_once().await.or_else(|err| {
                // Only terminate if the changeset channel has been closed.
                if let ProbeError::ChangesetSenderClosed(_) = err {
                    Err(err)
                } else {
                    Ok(())
                }
            })?;

            tokio::time::sleep(self.probe_interval).await;
        }
    }
/// Start probing the provided `hostname` for IP address changes.
/// The function will error if the receiving end of the tonic balance channel
/// is closed, e.g, the client has been deconstructed.
/// Any other errors are seen as transient, and therefore retried after `self.probe_interval`.
Start probing the provided `hostname` for IP address changes.
The function will error if the receiving end of the tonic balance channel
is closed, e.g, the client has been deconstructed.
Any other errors are seen as transient, and therefore retried after `self.probe_interval`.
Start probing the provided ` hostname ` for IP address changes . The function will error if the receiving end of the tonic balance channel is closed e . g the client has been deconstructed . Any other errors are seen as transient and therefore retried after ` self . probe_interval ` .
pub async fn probe(mut self) -> Result<(), anyhow::Error> {
        loop {
            self.probe_once().await.or_else(|err| {
                // Only terminate if the changeset channel has been closed.
                if let ProbeError::ChangesetSenderClosed(_) = err {
                    Err(err)
                } else {
                    Ok(())
                }
            })?;
            tokio::time::sleep(self.probe_interval).await;
        }
    }
pub async fn probe ( mut self ) -> Result < ( ) , anyhow :: Error > { loop { self . probe_once ( ) . await . or_else ( | err | { // Only terminate if the changeset channel has been closed. if let ProbeError :: ChangesetSenderClosed ( _ ) = err { Err ( err ) } else { Ok ( ( ) ) } } ) ? ; tokio :: time :: sleep ( self . probe_interval ) . await ; } }
Start probing the provided `hostname` for IP address changes.
Start probing the provided ` hostname ` for IP address changes .
mut self