Asiries335\redisSteamPhp\Consumer\Manager\TcpConsumerManager

Complexity

Total Complexity

4

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setConsumers()	0	2	1
A	list()	0	2	1
A	handle()	0	3	2

<?php

namespace Asiries335\redisSteamPhp\Consumer\Manager;

use Asiries335\redisSteamPhp\Consumer\ConsumerInterface;

class TcpConsumerManager implements ConsumerManagerInterface
{
    /**
     * @var ConsumerInterface[]
     */
    private array $consumers;

    /**
     * @param ConsumerInterface[] $consumers
     * @return void
     */
    public function setConsumers(array $consumers): void {
       $this->consumers = $consumers;
    }

    /**
     * @param mixed $payload
     * @return void
     */
    public function handle($payload): void {
        foreach ($this->consumers as $consumer) {
            $consumer->handle($payload);
        }
    }

    /**
     * @return ConsumerInterface[]
     */
    public function list(): array {
        return $this->consumers;
    }
}