pipx 0.1.0

Composable pipelines for Rust with synchronous and asynchronous execution, middleware-style processing, and predictable data flow.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

#![cfg(feature = "macros")]

use pipx::{Next, Pipeline, PipelineError, PipelineResult, pipe};

#[pipe(String, PipelineError)]
struct MacroMiddleware;

impl MacroMiddleware {
    fn handle(&self, passable: String, next: Next<'_, String>) -> PipelineResult<String> {
        next.handle(format!("macro:{passable}"))
    }
}

#[test]
fn pipe_macro_implements_pipe_trait() {
    let result = Pipeline::new()
        .send("hello".to_string())
        .when(true, MacroMiddleware)
        .then_return()
        .unwrap();

    assert_eq!(result, "macro:hello");
}