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
24
25
26
27

use crate::{Next, PipelineError, PipelineResult};

/// Defines a pipeline step.
///
/// A pipe receives the current value and a [`Next`] continuation.
/// It may continue the pipeline, stop execution early, wrap the downstream
/// result, or return an error.
///
/// **Generics**
/// - `TPassable` - The value processed by the pipeline.
/// - `TError` - The error type returned by the pipe.
pub trait Pipe<TPassable, TError = PipelineError> {
    /// Handles the current pipeline value.
    ///
    /// **Parameters**
    /// - `passable` - The current value being passed through the pipeline.
    /// - `next` - The continuation for the remaining pipeline steps.
    ///
    /// **Returns**
    /// - `Ok(TPassable)` - The value produced by the pipe or the remaining pipeline steps.
    /// - `Err(TError)` - The pipe failed and stopped pipeline execution.
    fn handle(
        &self,
        passable: TPassable,
        next: Next<'_, TPassable, TError>,
    ) -> PipelineResult<TPassable, TError>;
}