Final Class Yiisoft\Queue\Adapter\SynchronousAdapter

                public function __construct(
    private readonly WorkerInterface $worker,
    private readonly QueueInterface $queue,
) {}

            

                public function __destruct()
{
    $this->runExisting(function (MessageInterface $message): bool {
        $this->worker->process($message, $this->queue);
        return true;
    });
}

            

                public function push(MessageInterface $message): MessageInterface
{
    $key = count($this->messages) + $this->current;
    $this->messages[] = $message;
    return new IdEnvelope($message, $key);
}

            

                public function runExisting(callable $handlerCallback): void
{
    $result = true;
    while (isset($this->messages[$this->current]) && $result === true) {
        $result = $handlerCallback($this->messages[$this->current]);
        unset($this->messages[$this->current]);
        $this->current++;
    }
}

            

                public function status(string|int $id): JobStatus
{
    $id = (int) $id;
    if ($id < 0) {
        throw new InvalidArgumentException('This adapter IDs start with 0.');
    }
    if ($id < $this->current) {
        return JobStatus::DONE;
    }
    if (isset($this->messages[$id])) {
        return JobStatus::WAITING;
    }
    throw new InvalidArgumentException('There is no message with the given ID.');
}

            

                public function subscribe(callable $handlerCallback): void
{
    $this->runExisting($handlerCallback);
}