meadow 0.4.0

Robotics-focused middleware for embedded Linux
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
37
38

use crate::node::network_config::{Nonblocking, Quic};
use crate::node::Node;
use crate::node::Subscription;
use crate::prelude::*;

impl<T: Message + 'static> Node<Nonblocking, Quic, Subscription, T> {
    // Should actually return a <T>
    pub async fn get_subscribed_data(&self) -> Result<Msg<T>, Error> {
        let data = self.subscription_data.clone();
        let data = data.lock().await;
        match data.clone() {
            Some(data) => Ok(data),
            None => Err(Error::NoSubscriptionValue),
        }
    }
}

// ----------

use crate::node::network_config::Blocking;

impl<T: Message + 'static> Node<Blocking, Quic, Subscription, T> {
    // Should actually return a <T>
    pub fn get_subscribed_data(&self) -> Result<Msg<T>, Error> {
        let data = self.subscription_data.clone();
        let handle = match &self.rt_handle {
            Some(handle) => handle,
            None => return Err(Error::HandleAccess),
        };
        handle.block_on(async {
            let data = data.lock().await;
            match data.clone() {
                Some(data) => Ok(data),
                None => Err(Error::NoSubscriptionValue),
            }
        })
    }
}