pollination 0.1.0

An experimental library exposing hybrid Raft and CRDT primitives.
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

use crate::{ds::WalkieTalkie, nucleus::Nucleus};
use tokio::task::JoinHandle;

pub struct FlowerHandle<A> {
    flower_comm: WalkieTalkie<(), Nucleus<A>>,
    handle: JoinHandle<anyhow::Result<()>>,
}

impl<A> FlowerHandle<A> {
    /*
    pub fn pollinator<P: Pollinator + 'static>(&self, interval: Duration) -> P {
        let (pollinator, inner) = P::from_conn(EngineConnection {});
        pollinator
    }
    */

    pub(crate) fn new(
        flower_comm: WalkieTalkie<(), Nucleus<A>>,
        handle: JoinHandle<anyhow::Result<()>>,
    ) -> Self {
        Self {
            flower_comm,
            handle,
        }
    }

    pub async fn data(&mut self) -> Option<Nucleus<A>> {
        self.flower_comm.send_recv(()).await
    }

    pub async fn runtime(self) -> anyhow::Result<()> {
        self.handle.await??;
        Ok(())
    }
}