The `save-state` command is deprecated and will be disabled soon. Please upgrade to using Environment Files. For more information see: https://github.blog/changelog/2022-10-11-github-actions-deprecating-save-state-and-set-output-commands/

The `save-state` command is deprecated and will be disabled soon. Please upgrade to using Environment Files. For more information see: https://github.blog/changelog/2022-10-11-github-actions-deprecating-save-state-and-set-output-commands/

The `set-output` command is deprecated and will be disabled soon. Please upgrade to using Environment Files. For more information see: https://github.blog/changelog/2022-10-11-github-actions-deprecating-save-state-and-set-output-commands/

Escaped Mutant for Mutator "NotIdentical": @@ @@ $consumerRecords = new ConsumerRecords(); $this->doStart($timeoutMs, function (Message $message) use ($maxBatchSize, $timeoutMs, $batchTime, $processRecord, $onBatchProcessed, $consumerRecords): void { $consumerRecords->add($message); - if ($processRecord !== null) { + if ($processRecord === null) { $processRecord($message); } if ($consumerRecords->count() === $maxBatchSize) {

Escaped Mutant for Mutator "FunctionCallRemoval": @@ @@ $this->doStart($timeoutMs, function (Message $message) use ($maxBatchSize, $timeoutMs, $batchTime, $processRecord, $onBatchProcessed, $consumerRecords): void { $consumerRecords->add($message); if ($processRecord !== null) { - $processRecord($message); + } if ($consumerRecords->count() === $maxBatchSize) { if ($onBatchProcessed !== null && !$consumerRecords->isEmpty()) {

Escaped Mutant for Mutator "LogicalAnd": @@ @@ $processRecord($message); } if ($consumerRecords->count() === $maxBatchSize) { - if ($onBatchProcessed !== null && !$consumerRecords->isEmpty()) { + if ($onBatchProcessed !== null || !$consumerRecords->isEmpty()) { $onBatchProcessed($consumerRecords); } $consumerRecords->clear();

Escaped Mutant for Mutator "MethodCallRemoval": @@ @@ if ($onBatchProcessed !== null && !$consumerRecords->isEmpty()) { $onBatchProcessed($consumerRecords); } - $consumerRecords->clear(); + $batchTime->reset($timeoutMs, new DateTimeImmutable()); return; }

Escaped Mutant for Mutator "MethodCallRemoval": @@ @@ $onBatchProcessed($consumerRecords); } $consumerRecords->clear(); - $batchTime->reset($timeoutMs, new DateTimeImmutable()); + return; } $this->checkBatchTimedOut($timeoutMs, $batchTime, $onBatchProcessed, $consumerRecords)();

Escaped Mutant for Mutator "FunctionCallRemoval": @@ @@ $batchTime->reset($timeoutMs, new DateTimeImmutable()); return; } - $this->checkBatchTimedOut($timeoutMs, $batchTime, $onBatchProcessed, $consumerRecords)(); + }, $this->checkBatchTimedOut($timeoutMs, $batchTime, $onBatchProcessed, $consumerRecords), $this->checkBatchTimedOut($timeoutMs, $batchTime, $onBatchProcessed, $consumerRecords)); } /**

Escaped Mutant for Mutator "MethodCallRemoval": @@ @@ */ private function doStart(int $timeoutMs, callable $onSuccess, callable|null $onPartitionEof = null, callable|null $onTimedOut = null): void { - $this->registerSignals($this->shouldRun); + while ($this->shouldRun) { $message = $this->consume($timeoutMs); switch ($message->err) {

Escaped Mutant for Mutator "ArrayItemRemoval": @@ @@ break; default: $exception = IncompatibleStatus::fromMessage($message); - $this->logger->error($exception->getMessage(), ['exception' => $exception]); + $this->logger->error($exception->getMessage(), []); } pcntl_signal_dispatch(); }

Escaped Mutant for Mutator "MethodCallRemoval": @@ @@ break; default: $exception = IncompatibleStatus::fromMessage($message); - $this->logger->error($exception->getMessage(), ['exception' => $exception]); + } pcntl_signal_dispatch(); }