bissel 0.2.0

Robotics-focused publish-subscribe/request-reply middleware for embedded Linux
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::*;

use std::error::Error;
use std::result::Result;

impl<T: Message + 'static> Node<Subscription, T> {
    // Should actually return a <T>
    pub fn get_subscribed_data(&self) -> Result<Option<T>, Box<dyn Error>> {
        let data = self.subscription_data.clone();
        let result = self.runtime.block_on(async {
            let data = data.lock().await;
            match data.clone() {
                Some(value) => Some(value.data),
                None => None,
            }
        });
        Ok(result)
    }
}