1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use crate::*;
use std::ops::Deref;

impl<T: Message + 'static> Node<Tcp, Subscription, T> {
    pub fn get_subscribed_data(&self) -> Result<Msg<T>, crate::Error> {
        self.rt_handle.block_on(async {
            let data = self.subscription_data.lock().await.clone();
            if let Some(msg) = data {
                Ok(msg)
            } else {
                Err(Error::NoSubscriptionValue)
            }
        })
    }
}