README

PHP Pipeline 模式。

通过 composer 安装

$ composer require b2pweb/bdf-pipeline

使用说明

使用管道处理器的基本和经典管道使用。

use Bdf\Pipeline\Pipeline;
use Bdf\Pipeline\CallableFactory\LinkedCallableFactory;

$pipeline = new Pipeline(new LinkedCallableFactory());
$pipeline->pipe(function($value) {
    return $value + 2;
});

// Returns 12
$pipeline->send(10);

管道库自带一个高级处理器（默认使用）。

use Bdf\Pipeline\Pipeline;
use Bdf\Pipeline\CallableFactory\StackCallableFactory;

$pipeline = new Pipeline(new StackCallableFactory());
$pipeline->pipe(function($next, $foo, $bar) {
    // Do something
    ...
    
    $result = $next($foo, $bar);
    
    // Do something else
    ...
    
    return $result;
});
$pipeline->outlet(function($foo, $bar) {
    return "${foo}.${bar}";
});
// Manage multiple parameters
echo $pipeline->send('foo', 'bar'); // Print foo.bar

那么呢？

您可以将此包用作经典管道，但它被设计为易于扩展

$pipeline->pipe(new LogCommand());
$pipeline->outlet(new CreateUserHandler());

...

$pipeline->prepend(new TransactionnalCommand());
$pipeline->send(new CreateUserCommand());

class TransactionnalCommand
{
    public function __invoke($next, $command)
    {
        try {
            $result = $next($command);
            
            // Commit and return the result
            ...
            return $result;
        } catch (\Throwable $exception) {
            // Rollback and propagate exception
            throw $exception;
        }
    }
}

管道可重用

$pipeline = new Pipeline();
$pipeline->pipe(new Double());

$new = clone $pipeline;

$new->pipe(new Double());

echo $pipeline->send(2); // 4
echo $new->send(2); // 8

许可证

在 MIT 许可证的条款下分发。