rill-engine 0.41.0

The RillRate Protocol async engine.
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
39
40
41
42
43

pub mod parcel;

use crate::actors::engine::RillEngine;
use anyhow::Error;
use async_trait::async_trait;
use meio::{Actor, Context, InterruptedBy, StartedBy};

pub struct RillPool {}

impl RillPool {
    #[allow(clippy::new_without_default)]
    pub fn new() -> Self {
        Self {}
    }
}

#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum Group {
    ParcelStream,
    Tasks,
}

impl Actor for RillPool {
    type GroupBy = Group;
}

#[async_trait]
impl StartedBy<RillEngine> for RillPool {
    async fn handle(&mut self, ctx: &mut Context<Self>) -> Result<(), Error> {
        ctx.termination_sequence(vec![Group::ParcelStream, Group::Tasks]);
        self.attach_distributor(ctx).await?;
        Ok(())
    }
}

#[async_trait]
impl InterruptedBy<RillEngine> for RillPool {
    async fn handle(&mut self, ctx: &mut Context<Self>) -> Result<(), Error> {
        self.detach_distributor();
        ctx.shutdown();
        Ok(())
    }
}