for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace AlexManno\Remix\Pipelines;
use AlexManno\Remix\Pipelines\Interfaces\PipelineInterface;
use AlexManno\Remix\Pipelines\Interfaces\StageInterface;
use AlexManno\Remix\Pipelines\Interfaces\PayloadInterface;
use SplQueue;
class Pipeline implements PipelineInterface
{
/** @var SplQueue */
private $stages;
/**
* Pipeline constructor.
*/
public function __construct()
$this->stages = new SplQueue();
}
public function pipe(StageInterface $stage): PipelineInterface
$this->stages->enqueue($stage);
return $this;
public function getStages(): \SplQueue
return $this->stages;
public function add(PipelineInterface $pipeline): PipelineInterface
$queue = $pipeline->getStages();
$queue->rewind();
while ($queue->valid()) {
$this->stages->enqueue($queue->current());
$queue->next();
public function count(): int
return $this->stages->count();
public function __invoke(PayloadInterface $payload): PayloadInterface
$this->stages->rewind();
while ($this->stages->valid()) {
$payload = $this->stages->current()($payload);
$this->stages->next();
return $payload;
alexmanno /
pipeline-remix
