*/ private array $pipes = []; /** * The list of passables. * * @var array */ private array $passables; /** * The expectation closure. */ private Closure $closure; /** * Creates a new instance of Expectation Pipeline. */ public function __construct(Closure $closure) { $this->closure = $closure; } /** * Creates a new instance of Expectation Pipeline with given closure. */ public static function for(Closure $closure): self { return new self($closure); } /** * Sets the list of passables. */ public function send(mixed ...$passables): self { $this->passables = array_values($passables); return $this; } /** * Sets the list of pipes. * * @param array $pipes */ public function through(array $pipes): self { $this->pipes = $pipes; return $this; } /** * Runs the pipeline. */ public function run(): void { $pipeline = array_reduce( array_reverse($this->pipes), $this->carry(), function (): void { ($this->closure)(...$this->passables); } ); $pipeline(); } /** * Get a Closure that will carry of the expectation. */ public function carry(): Closure { return function ($stack, $pipe): Closure { return function () use ($stack, $pipe) { return $pipe($stack, ...$this->passables); }; }; } }