streams/
streams.rs

1use std::error::Error;
2
3use krpc_client::{client::Client, services::space_center::SpaceCenter};
4
5/// This example creates a stream of get_ut(), awaiting
6/// updates at a rate of 1Hz.
7fn main() -> Result<(), Box<dyn Error>> {
8    let client = Client::new("kRPC TEST", "127.0.0.1", 50000, 50001)?;
9
10    let space_center = SpaceCenter::new(client.clone());
11
12    // Set up a stream.
13    let ut_stream = space_center.get_ut_stream()?;
14    ut_stream.set_rate(1f32)?;
15
16    // Wait for updates, and print the current value.
17    for _ in 0..10 {
18        ut_stream.wait();
19        println!("It's {} o'clock", ut_stream.get()?);
20    }
21
22    Ok(())
23}