for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace League\Pipeline;
class Pipeline implements PipelineInterface
{
/**
* @var callable[]
*/
private array $stages;
private ProcessorInterface $processor;
public function __construct(?ProcessorInterface $processor = null, callable ...$stages)
$this->processor = $processor ?? new FingersCrossedProcessor;
$this->stages = $stages;
}
public function pipe(callable $operation): PipelineInterface
$pipeline = clone $this;
$pipeline->stages[] = $operation;
return $pipeline;
public function process($payload)
return $this->processor->process($payload, ...$this->stages);
public function __invoke($payload)
return $this->process($payload);
thephpleague /
pipeline
