anathema_runtime/runtime/
testing.rs

1use std::time::{Duration, Instant};
2
3use anathema_backend::Backend;
4use anathema_state::{Watched, Watcher, drain_watchers};
5use anathema_store::stack::Stack;
6
7use crate::Frame;
8use crate::error::Result;
9use crate::events::GlobalEventHandler;
10
11// -----------------------------------------------------------------------------
12//   - Used with test driver -
13//   These functions should not be used outside of testing
14// -----------------------------------------------------------------------------
15impl<'bp, G> Frame<'_, 'bp, G>
16where
17    G: GlobalEventHandler,
18{
19    // TODO: Do we need this for anything? - TB 2025-08-27
20    // pub fn elements(&mut self) -> Children<'_, 'bp> {
21    //     Children::new(
22    //         self.tree.view(),
23    //         self.layout_ctx.attribute_storage,
24    //         &mut self.needs_layout,
25    //     )
26    // }
27
28    // TODO: this can't really be called a frame if we can tick it multiple
29    // times. Maybe RuntimeMut or something less mental
30    pub fn wait_for_monitor<B: Backend>(
31        &mut self,
32        backend: &mut B,
33        watcher: Watcher,
34        timeout: Duration,
35    ) -> Result<Watched> {
36        let now = Instant::now();
37
38        let mut watchers = Stack::empty();
39        drain_watchers(&mut watchers);
40
41        if watchers.contains(&watcher) {
42            return Ok(Watched::Triggered);
43        }
44
45        loop {
46            let dur = self.tick(backend)?;
47            self.present(backend);
48            self.cleanup();
49
50            drain_watchers(&mut watchers);
51
52            if watchers.contains(&watcher) {
53                return Ok(Watched::Triggered);
54            }
55
56            if timeout.saturating_sub(now.elapsed()).is_zero() {
57                break Ok(Watched::Timeout);
58            }
59
60            let sleep = self.sleep_micros - dur.as_micros() as u64;
61            std::thread::sleep(Duration::from_micros(sleep));
62        }
63    }
64}
anathema_runtime/runtime/testing.rs

anathema_runtime/runtime/
testing.rs
