colink 0.3.10

CoLink Rust SDK
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

use crate::colink_proto::*;
use tracing::debug;

type Error = Box<dyn std::error::Error + Send + Sync + 'static>;

impl crate::application::CoLink {
    pub async fn read_or_wait(&self, key: &str) -> Result<Vec<u8>, Error> {
        match self.read_entry(key).await {
            Ok(res) => Ok(res),
            Err(e) => {
                let queue_name = self.subscribe(key, Some(0)).await?;
                let mut subscriber = self.new_subscriber(&queue_name).await?;
                let data = subscriber.get_next().await?;
                debug!("Received [{}]", String::from_utf8_lossy(&data));
                self.unsubscribe(&queue_name).await?;
                let message: SubscriptionMessage = prost::Message::decode(&*data).unwrap();
                if message.change_type != "delete" {
                    Ok((*message.payload).to_vec())
                } else {
                    Err(e)
                }
            }
        }
    }
}