Genkgo\Mail\Queue\FlushableQueue

Complexity

Total Complexity

6

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	flush()	0	12	3
A	store()	0	4	1
A	fetch()	0	4	1

<?php

namespace Genkgo\Mail\Queue;

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

/**
 * Class FlushableQueue
 * @package Genkgo\Mail\Queue
 */
final class FlushableQueue implements QueueInterface
{
    /**
     * @var QueueInterface
     */
    private $decoratedQueue;

    public function __construct(QueueInterface $queue)
    {
        $this->decoratedQueue = $queue;
    }

    public function flush(): int
    {
        $count = 0;
        try {
            while ($this->decoratedQueue->fetch()) {
                ++$count;
            }
        } catch (EmptyQueueException $e) {

Consider adding a comment why this CATCH block is empty.

        }

        return $count;
    }

    /**
     * {@inheritdoc}
     */
    public function store(MessageInterface $message): void
    {
        $this->decoratedQueue->store($message);
    }

    /**
     * {@inheritdoc}
     */
    public function fetch(): MessageInterface
    {
        return $this->decoratedQueue->fetch();
    }
}