coordinator 0.1.1

Coordinator is a library to load balance tasks into task runners
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

use std::{error::Error, fmt::Display, future::Future};

#[derive(Debug)]
pub struct TaskProcessErr;

impl Error for TaskProcessErr {}

impl Display for TaskProcessErr {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.write_str("Error occurred while processing the current task!")
    }
}

#[derive(Debug)]
pub enum TaskPrefs<T> {
    Any,
    Preferred(T),
    Required(T),
}

pub trait TaskProcessor<I> {
    type Output;
    fn do_work(&mut self, task: I) -> impl Future<Output = Self::Output> + Send;
}

impl<F, I, O, Fut> TaskProcessor<I> for F
where
    F: FnMut(I) -> Fut,
    Fut: Future<Output = O> + Send,
{
    type Output = O;

    fn do_work(&mut self, task: I) -> impl Future<Output = Self::Output> + Send {
        self(task)
    }
}