1  use std::time;
 2  
 3  use radicle::node::Handle;
 4  
 5  pub fn run(node: impl Handle, count: usize, timeout: time::Duration) -> anyhow::Result<()> {
 6      let events = node.subscribe(timeout)?;
 7      for (i, event) in events.enumerate() {
 8          let event = event?;
 9          let obj = serde_json::to_string(&event)?;
10  
11          println!("{obj}");
12  
13          // Only output up to `count` events.
14          if i + 1 >= count {
15              break;
16          }
17      }
18  
19      Ok(())
20  }