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 InterruptibleProcessor implements ProcessorInterface
{
/**
* @var callable
*/
private $check;
public function __construct(callable $check)
$this->check = $check;
}
public function process($payload, callable ...$stages)
$check = $this->check;
foreach ($stages as $stage) {
$payload = $stage($payload);
if (true !== $check($payload)) {
return $payload;
thephpleague /
pipeline
