async-flow 0.1.5

Async abstractions for flow-based programming (FBP).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

// This is free and unencumbered software released into the public domain.

pub fn bounded<T>(buffer: usize) -> (Outputs<T>, Inputs<T>) {
    let (tx, rx) = flume::bounded(buffer);
    let outputs = Outputs::from(tx);
    let inputs = Inputs::from(rx);
    (outputs, inputs)
}

mod inputs;
pub use inputs::*;

mod outputs;
pub use outputs::*;