crb-parallel 0.0.20

CRB | Composable Runtime Blocks | Parallel
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use anyhow::Result;
use async_trait::async_trait;

#[async_trait]
pub trait Concurrent {
    type Context;
    type Input;
    type Output;

    async fn initialize(&mut self, _ctx: &mut Self::Context) -> Result<()> {
        Ok(())
    }

    async fn map(&mut self, ctx: &mut Self::Context) -> Option<Self::Input>;

    async fn task(input: Self::Input) -> Self::Output;

    async fn reduce(&mut self, output: Self::Output, ctx: &mut Self::Context);

    async fn finalize(&mut self, _ctx: &mut Self::Context) -> Result<()> {
        Ok(())
    }
}