pub fn run(&mut self) {
        loop {
            thread::sleep(self.timestamp_frequency);
            let shutdown = self.update_sources();
            if shutdown {
                return;
            } else {
                self.update_byo_timestamp();
            }
        }
    }
/// Run the update function in a loop at the specified frequency. Acquires timestamps using
/// either the Kafka topic ground truth
/// TODO(ncrooks): move to thread local BYO implementation
Run the update function in a loop at the specified frequency. Acquires timestamps using
either the Kafka topic ground truth
TODO(ncrooks): move to thread local BYO implementation
Run the update function in a loop at the specified frequency . Acquires timestamps using either the Kafka topic ground truth TODO ( ncrooks ) : move to thread local BYO implementation
pub fn run(&mut self) {
        loop {
            thread::sleep(self.timestamp_frequency);
            let shutdown = self.update_sources();
            if shutdown {
                return;
            } else {
                self.update_byo_timestamp();
            }
        }
    }
pub fn run ( & mut self ) { loop { thread :: sleep ( self . timestamp_frequency ) ; let shutdown = self . update_sources ( ) ; if shutdown { return ; } else { self . update_byo_timestamp ( ) ; } } }
Run the update function in a loop at the specified frequency.
Run the update function in a loop at the specified frequency .
&mut self
&mut self