#pipeline #pipe #system #fluent #class

fluent_pipeline

A lightweight pipeline system for Rust

1 unstable release

Uses new Rust 2024

0.1.0 Feb 3, 2025

#27 in #fluent

Download history 81/week @ 2025-01-29 34/week @ 2025-02-05 4/week @ 2025-02-12

69 downloads per month

MIT license

5KB

Pipeline for Rust

crates.io download count badge docs.rs

A convenient way to "pipe" a given input through a series of invokable classes, closures, or callables, giving each class the opportunity to inspect or modify the input and invoke the next callable in the pipeline.

Usage

To get started, create a new pipeline with the send method, passing the input you want to pipe through the pipeline. Then, use the through method to add a series of pipes (either classes implenting the Pipe trait, or closures) to the pipeline. Finally, call the then method to transform and get the final output.

You can also append Pipes to an existing pipeline using the pipe method, or use thenReturn to get the final output without transforming it.

use fluent_pipeline::Pipeline;

Pipeline::send(project).through(&[
    PipeType::Pipe(BuildProject()),
    PipeType::Pipe(UploadProject()),
    PipeType::Pipe(DeployProject()),
    PipeType::Fn(|project| {
        // ...

        return project
    })
]).run()

License

This project is licensed under the MIT License - see the LICENSE file for details.

No runtime deps