PHP Decode

<?php

/**
 * This file is part of the reliforp/reli-prof package.
 *
 * (c) sji <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Reli\Lib\Loop\AsyncLoopMiddleware;

use Reli\Lib\Log\Log;
use Reli\Lib\Loop\AsyncLoopMiddlewareInterface;

class ExitLoopOnSpecificExceptionMiddlewareAsync implements AsyncLoopMiddlewareInterface
{
    /** @param array<class-string<\Throwable>> $exception_names */
    public function __construct(
        private array $exception_names,
        private AsyncLoopMiddlewareInterface $chain
    ) {
    }

    public function invoke(): \Generator
    {
        try {
            yield from $this->chain->invoke();
        } catch (\Throwable $e) {
            foreach ($this->exception_names as $exception_name) {
                /** @psalm-suppress DocblockTypeContradiction */
                if (is_a($e, $exception_name)) {
                    Log::debug(
                        $e->getMessage(),
                        [
                            'trace' => $e->getTrace()
                        ]
                    );
                    return;
                }
            }
            throw $e;
        }
    }
}
 ?>