Lines Matching refs:clock
100 let clock = Clock::new(); in run() localVariable
103 block_on(clock.clone(), async move { in run()
106 clock, in run()
168 clock: Clock, field
246 clock: self.clone(), in timer()
259 clock: Clock, field
265 let now = self.clock.get(); in poll()
419 fn block_on<R>(clock: Clock, f: impl Future<Output = Result<R>> + Send + 'static) -> Result<R> { in block_on()
450 clock.set(sleep_until); in block_on()
452 clock.set(clock.get() + 1); in block_on()
456 for waker in executor.0.borrow_mut().ready_deadlines(clock.get()) { in block_on()
476 Ok(self.clock.get()) in now()
485 self.subscribe_instant(self.clock.get() + duration) in subscribe_duration()
491 let timer = self.clock.timer(deadline); in subscribe_instant()
501 let now = self.clock.get(); in now()