nt_client 0.5.1

A blazingly fast NetworkTables 4.1 client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! An example of using a TopicCollection to subscribe to multiple topics.

use nt_client::{subscribe::ReceivedMessage, Client};

#[tokio::main]
async fn main() {
    let client = Client::new(Default::default());

    client.connect_setup(setup).await.unwrap();
}

fn setup(client: &Client) {
    let topic_names = vec!["/topic1".to_owned(), "/topic2".to_owned(), "topic3".to_owned()];
    let topics = client.topics(topic_names);

    // loop over topics in the collection
    for topic in topics.clone() {
        println!("{topic:?}");

        // do something with topic
    }

    tokio::spawn(async move {
        // subscribe to `/topic1`, `/topic2`, and `/topic3`
        let mut sub = topics.subscribe(Default::default()).await.unwrap();

        loop {
            match sub.recv().await {
                Ok(ReceivedMessage::Updated((topic, value))) => println!("topic {} updated to {value:?}", topic.name()),
                Err(_) => break,
                _ => {},
            }
        }
    });
}