elfo-core 0.1.35

The core of the system
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 std::sync::Arc;

use smallvec::SmallVec;

use crate::{addr::Addr, envelope::Envelope};

const OPTIMAL_COUNT: usize = 5;

#[derive(Default, Clone)]
pub(crate) struct Demux {
    list: SmallVec<[(Addr, Filter); OPTIMAL_COUNT]>,
}

impl Demux {
    pub(crate) fn append(&mut self, addr: Addr, f: Filter) {
        self.list.push((addr, f));
    }

    pub(crate) fn filter(&self, envelope: &Envelope) -> SmallVec<[Addr; OPTIMAL_COUNT]> {
        // TODO: use a bitset as iterator's state.
        self.list
            .iter()
            .filter(|(_, filter)| match filter {
                Filter::Dynamic(filter) => filter(envelope),
            })
            .map(|(addr, _)| *addr)
            .collect()
    }
}

#[derive(Clone)]
pub(crate) enum Filter {
    // TODO: what about `smallbox`?
    Dynamic(Arc<dyn Fn(&Envelope) -> bool + Send + Sync>),
}