Escaped Mutant for Mutator "TrueValue": --- Original +++ New @@ @@ { $this->memorySoftLimit = $memorySoftLimit; foreach (self::SIGNALS_EXIT as $signal) { - pcntl_signal($signal, fn() => $this->exit = true); + pcntl_signal($signal, fn() => $this->exit = false); } foreach (self::SIGNALS_SUSPEND as $signal) { pcntl_signal($signal, fn() => $this->pause = true);

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ { $this->memorySoftLimit = $memorySoftLimit; foreach (self::SIGNALS_EXIT as $signal) { - pcntl_signal($signal, fn() => $this->exit = true); + } foreach (self::SIGNALS_SUSPEND as $signal) { pcntl_signal($signal, fn() => $this->pause = true);

Escaped Mutant for Mutator "TrueValue": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->exit = true); } foreach (self::SIGNALS_SUSPEND as $signal) { - pcntl_signal($signal, fn() => $this->pause = true); + pcntl_signal($signal, fn() => $this->pause = false); } foreach (self::SIGNALS_RESUME as $signal) { pcntl_signal($signal, fn() => $this->pause = false);

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->exit = true); } foreach (self::SIGNALS_SUSPEND as $signal) { - pcntl_signal($signal, fn() => $this->pause = true); + } foreach (self::SIGNALS_RESUME as $signal) { pcntl_signal($signal, fn() => $this->pause = false);

Escaped Mutant for Mutator "FalseValue": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->pause = true); } foreach (self::SIGNALS_RESUME as $signal) { - pcntl_signal($signal, fn() => $this->pause = false); + pcntl_signal($signal, fn() => $this->pause = true); } } /**

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->pause = true); } foreach (self::SIGNALS_RESUME as $signal) { - pcntl_signal($signal, fn() => $this->pause = false); + } } /**

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ } protected function dispatchSignals() : bool { - pcntl_signal_dispatch(); + // Wait for resume signal until loop is suspended while ($this->pause && !$this->exit) { usleep(10000);

Escaped Mutant for Mutator "LogicalNot": --- Original +++ New @@ @@ { pcntl_signal_dispatch(); // Wait for resume signal until loop is suspended - while ($this->pause && !$this->exit) { + while ($this->pause && $this->exit) { usleep(10000); pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "LogicalAndAllSubExprNegation": --- Original +++ New @@ @@ { pcntl_signal_dispatch(); // Wait for resume signal until loop is suspended - while ($this->pause && !$this->exit) { + while (!$this->pause && $this->exit) { usleep(10000); pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "While_": --- Original +++ New @@ @@ { pcntl_signal_dispatch(); // Wait for resume signal until loop is suspended - while ($this->pause && !$this->exit) { + while (false) { usleep(10000); pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "TrueValue": --- Original +++ New @@ @@ { $this->memorySoftLimit = $memorySoftLimit; foreach (self::SIGNALS_EXIT as $signal) { - pcntl_signal($signal, fn() => $this->exit = true); + pcntl_signal($signal, fn() => $this->exit = false); } foreach (self::SIGNALS_SUSPEND as $signal) { pcntl_signal($signal, fn() => $this->pause = true);

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ { $this->memorySoftLimit = $memorySoftLimit; foreach (self::SIGNALS_EXIT as $signal) { - pcntl_signal($signal, fn() => $this->exit = true); + } foreach (self::SIGNALS_SUSPEND as $signal) { pcntl_signal($signal, fn() => $this->pause = true);

Escaped Mutant for Mutator "TrueValue": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->exit = true); } foreach (self::SIGNALS_SUSPEND as $signal) { - pcntl_signal($signal, fn() => $this->pause = true); + pcntl_signal($signal, fn() => $this->pause = false); } foreach (self::SIGNALS_RESUME as $signal) { pcntl_signal($signal, fn() => $this->pause = false);

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->exit = true); } foreach (self::SIGNALS_SUSPEND as $signal) { - pcntl_signal($signal, fn() => $this->pause = true); + } foreach (self::SIGNALS_RESUME as $signal) { pcntl_signal($signal, fn() => $this->pause = false);

Escaped Mutant for Mutator "FalseValue": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->pause = true); } foreach (self::SIGNALS_RESUME as $signal) { - pcntl_signal($signal, fn() => $this->pause = false); + pcntl_signal($signal, fn() => $this->pause = true); } } /**

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ pcntl_signal($signal, fn() => $this->pause = true); } foreach (self::SIGNALS_RESUME as $signal) { - pcntl_signal($signal, fn() => $this->pause = false); + } } /**

Escaped Mutant for Mutator "FunctionCallRemoval": --- Original +++ New @@ @@ } protected function dispatchSignals() : bool { - pcntl_signal_dispatch(); + // Wait for resume signal until loop is suspended while ($this->pause && !$this->exit) { usleep(10000);

Escaped Mutant for Mutator "LogicalNot": --- Original +++ New @@ @@ { pcntl_signal_dispatch(); // Wait for resume signal until loop is suspended - while ($this->pause && !$this->exit) { + while ($this->pause && $this->exit) { usleep(10000); pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "LogicalAndAllSubExprNegation": --- Original +++ New @@ @@ { pcntl_signal_dispatch(); // Wait for resume signal until loop is suspended - while ($this->pause && !$this->exit) { + while (!$this->pause && $this->exit) { usleep(10000); pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "While_": --- Original +++ New @@ @@ { pcntl_signal_dispatch(); // Wait for resume signal until loop is suspended - while ($this->pause && !$this->exit) { + while (false) { usleep(10000); pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ public function status(string $id) : JobStatus { $result = $this->queue->status($id); - $this->collector->collectStatus($id, $result); + return $result; } public function push(MessageInterface $message, string|array|callable|MiddlewarePushInterface ...$middlewareDefinitions) : MessageInterface

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ public function push(MessageInterface $message, string|array|callable|MiddlewarePushInterface ...$middlewareDefinitions) : MessageInterface { $message = $this->queue->push($message, ...$middlewareDefinitions); - $this->collector->collectPush($this->queue->getChannelName(), $message, ...$middlewareDefinitions); + return $message; } public function run(int $max = 0) : void

Escaped Mutant for Mutator "DecrementInteger": --- Original +++ New @@ @@ $this->collector->collectPush($this->queue->getChannelName(), $message, ...$middlewareDefinitions); return $message; } - public function run(int $max = 0) : void + public function run(int $max = -1) : void { $this->queue->run($max); }

Escaped Mutant for Mutator "IncrementInteger": --- Original +++ New @@ @@ $this->collector->collectPush($this->queue->getChannelName(), $message, ...$middlewareDefinitions); return $message; } - public function run(int $max = 0) : void + public function run(int $max = 1) : void { $this->queue->run($max); }

Escaped Mutant for Mutator "DecrementInteger": --- Original +++ New @@ @@ * @param int $code * @param Throwable|null $previous */ - public function __construct(string $channel, $definition, int $code = 0, ?Throwable $previous = null) + public function __construct(string $channel, $definition, int $code = -1, ?Throwable $previous = null) { $adapterClass = AdapterInterface::class; $realType = get_debug_type($definition);

Escaped Mutant for Mutator "IncrementInteger": --- Original +++ New @@ @@ * @param int $code * @param Throwable|null $previous */ - public function __construct(string $channel, $definition, int $code = 0, ?Throwable $previous = null) + public function __construct(string $channel, $definition, int $code = 1, ?Throwable $previous = null) { $adapterClass = AdapterInterface::class; $realType = get_debug_type($definition);

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ $realType = get_debug_type($definition); $message = "Channel \"{$channel}\" is not properly configured: definition must return {$adapterClass}, {$realType} returned"; $this->channel = $channel; - parent::__construct($message, $code, $previous); + } public function getName() : string {

Escaped Mutant for Mutator "DecrementInteger": --- Original +++ New @@ @@ class ChannelNotConfiguredException extends InvalidArgumentException implements FriendlyExceptionInterface { private string $channel; - public function __construct(string $channel, int $code = 0, Throwable $previous = null) + public function __construct(string $channel, int $code = -1, Throwable $previous = null) { $message = "Queue channel \"{$channel}\" is not properly configured."; $this->channel = $channel;

Escaped Mutant for Mutator "IncrementInteger": --- Original +++ New @@ @@ class ChannelNotConfiguredException extends InvalidArgumentException implements FriendlyExceptionInterface { private string $channel; - public function __construct(string $channel, int $code = 0, Throwable $previous = null) + public function __construct(string $channel, int $code = 1, Throwable $previous = null) { $message = "Queue channel \"{$channel}\" is not properly configured."; $this->channel = $channel;