fn advance_to_next_telemetry_checkpoint(
            &mut self,
            test_fut: Pin<&mut impl Future<Output = ()>>,
        ) {
            let now = fasync::Time::now();
            let remaining_interval = TELEMETRY_QUERY_INTERVAL.into_nanos()
                - (now.into_nanos() % TELEMETRY_QUERY_INTERVAL.into_nanos());
            self.advance_by(zx::Duration::from_nanos(remaining_interval), test_fut)
        }
/// Advance executor by some duration until the next time `test_fut` handles periodic
/// telemetry. This uses `self.advance_by` underneath.
///
/// This function assumes that executor starts test_fut at time 0 (which should be true
/// if TestHelper is created from `setup_test()`)
Advance executor by some duration until the next time `test_fut` handles periodic
telemetry.

This function assumes that executor starts test_fut at time 0 (which should be true
if TestHelper is created from `setup_test()`)
Advance executor by some duration until the next time ` test_fut ` handles periodic telemetry . This function assumes that executor starts test_fut at time 0 ( which should be true if TestHelper is created from ` setup_test () ` )
fn advance_to_next_telemetry_checkpoint(
            &mut self,
            test_fut: Pin<&mut impl Future<Output = ()>>,
        ) {
            let now = fasync::Time::now();
            let remaining_interval = TELEMETRY_QUERY_INTERVAL.into_nanos()
                - (now.into_nanos() % TELEMETRY_QUERY_INTERVAL.into_nanos());
            self.advance_by(zx::Duration::from_nanos(remaining_interval), test_fut)
        }
fn advance_to_next_telemetry_checkpoint ( & mut self , test_fut : Pin < & mut impl Future < Output = ( ) > > , ) { let now = fasync :: Time :: now ( ) ; let remaining_interval = TELEMETRY_QUERY_INTERVAL . into_nanos ( ) - ( now . into_nanos ( ) % TELEMETRY_QUERY_INTERVAL . into_nanos ( ) ) ; self . advance_by ( zx :: Duration :: from_nanos ( remaining_interval ) , test_fut ) }
Advance executor by some duration until the next time `test_fut` handles periodic
telemetry.
Advance executor by some duration until the next time ` test_fut ` handles periodic telemetry .
&mut self
test_fut
Pin<&mut impl Future<Output = ()>>
&mut self
test_fut
Pin<&mut impl Future<Output = ()>>