README

composer require ledc/pipeline

使用 Usage

<?php
use Ledc\Pipeline\Pipeline;

//初始数据
class Request
{
 public int $number = 1;
}

//管道数组
$pipes = [];
foreach (range(1, 3) as $row) {
 $pipes[] = function ($request, $next) use ($row) {
 echo 'pipe-before' . $row . PHP_EOL;
 $request->number += $row;
 $request = $next($request);
 echo 'pipe-after' . $row . PHP_EOL;
 return $request;
 };
}

//核心逻辑
$init = function ($request) {
 echo 'init start' . PHP_EOL;
 var_dump($request);
 echo 'init end' . PHP_EOL;
 return 'init';
};

$pipeline = new Pipeline();
$result = $pipeline->send(new Request())
 ->through($pipes)
 ->then($init);

var_dump($result);