Werkspot\MessageQueue\ScheduledQueue\Repository\FailedMessageCollection

Complexity

Total Complexity

8

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	key()	0	3	1
A	next()	0	3	1
A	current()	0	3	1
A	count()	0	3	1
A	rewind()	0	3	1
A	valid()	0	3	1

<?php

namespace Werkspot\MessageQueue\ScheduledQueue\Repository;

use Countable;
use Iterator;
use Werkspot\MessageQueue\Message\MessageInterface;

final class FailedMessageCollection implements Countable, Iterator
{
    /**
     * @var array
     */
    private $failedMessages = [];

    /**
     * @var int
     */
    private $pointer = 0;

    public function __construct(array $failedMessagesArray)
    {
        /**
         * @var MessageInterface $message
         * @var int $count
         */
        foreach ($failedMessagesArray as [$message, $count]) {
            $this->failedMessages[] = new FailedMessage($message, $count);
        }
    }

    public function current(): FailedMessage
    {
        return $this->failedMessages[$this->pointer];
    }

    public function next(): void
    {
        $this->pointer++;
    }

    public function key(): int
    {
        return $this->pointer;
    }

    public function valid(): bool
    {
        return isset($this->failedMessages[$this->pointer]);
    }

    public function rewind(): void
    {
        $this->pointer = 0;
    }

    public function count(): int
    {
        return count($this->failedMessages);
    }
}