Genkgo\Mail\Queue\ArrayObjectQueue

Complexity

Total Complexity

5

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	store()	0	4	1
A	fetch()	0	9	2
A	count()	0	4	1

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Queue;

use Genkgo\Mail\Exception\EmptyQueueException;
use Genkgo\Mail\GenericMessage;
use Genkgo\Mail\MessageInterface;

/**
 * Class ArrayObjectQueue
 * @package Genkgo\Mail\Queue
 */
final class ArrayObjectQueue implements QueueInterface, \Countable
{
    /**
     * @var \ArrayObject
     */
    private $storage;

    /**
     * ArrayObjectQueue constructor.
     * @param \ArrayObject $storage
     */
    public function __construct(\ArrayObject $storage)
    {
        $this->storage = $storage;
    }

    /**
     * @param MessageInterface $message
     */
    public function store(MessageInterface $message): void
    {
        $this->storage->append((string)$message);
    }

    /**
     * @return MessageInterface
     * @throws EmptyQueueException
     */
    public function fetch(): MessageInterface
    {
        foreach ($this->storage as $key => $item) {
            unset($this->storage[$key]);
            return GenericMessage::fromString($item);
        }

        throw new EmptyQueueException('No message left in queue');
    }

    /**
     * @return int
     */
    public function count(): int
    {
        return $this->storage->count();
    }
}