Hyperbee.Pipeline 1.1.2

Hyperbee.Pipeline

Classes for building composable async pipelines supporting:

• Value projections
• Early returns
• Child pipelines
• Middleware
• Conditional flow
• Dependency Injection

Usage

// Takes a string and returns a number
var question = PipelineFactory
    .Start<string>()
    .PipeIf((ctx, arg) => arg == "Adams", builder => builder
        .Pipe((ctx, arg) => 42)
        .Cancel()
    )
    .Pipe((ctx, arg) => 0)
    .Build();

var answer1 = await question(new PipelineContext(), "Adams");
Assert.AreEqual(42, answer1);

var answer2 = await question(new PipelineContext(), "Smith");
Assert.AreEqual(0, answer2);

Status

Branch	Action
develop
main

Help

See Todo