rust-elm 0.6.0

Elm Architecture for Rust: composable reducers, pure effects, async runtime.
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

/// Configuration for [`super::engine::Runtime::from_program`] / [`super::engine::Runtime::from_reducer_program`].
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct RuntimeConfig {
    /// Bounded capacity of the action bus (`send_blocking` back-pressures when full).
    pub bus_capacity: usize,
    /// Tokio runtime worker threads (async effects / subscriptions).
    pub worker_threads: usize,
    /// Name of the dedicated reducer thread.
    pub thread_name: &'static str,
}

impl Default for RuntimeConfig {
    fn default() -> Self {
        Self {
            bus_capacity: 4_096,
            worker_threads: std::thread::available_parallelism()
                .map(|n| n.get())
                .unwrap_or(1),
            thread_name: "rust-elm",
        }
    }
}

impl RuntimeConfig {
    /// `bus_capacity` only; other fields from [`Default`].
    pub fn new(bus_capacity: usize) -> Self {
        Self {
            bus_capacity,
            ..Self::default()
        }
    }
}