Wonderland\Thread\AbstractThreadPoolMediator

Complexity

Total Complexity

5

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Test Coverage

Coverage

23.08%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	addListener()	0	5	1
A	getMediator()	0	3	1
A	removeListener()	0	5	1
A	notify()	0	3	1

<?php

namespace Wonderland\Thread;

use Wonderland\Thread\Mediator\Listener\ListenerInterface;
use Wonderland\Thread\Mediator\Mediator;
use Wonderland\Thread\Factory\EventPoolFactory;

abstract class AbstractThreadPoolMediator
{
	/** @var Mediator */
	private $mediator;

	/**
	 * @return Mediator
	 */
	protected function getMediator()
	{
		return $this->mediator;
	}

	/**
	 * ThreadPoolMediator constructor.
	 */
	public function __construct()
	{
		$this->mediator = new Mediator();
	}

	/**
	 * @param ListenerInterface $listener
	 * @return AbstractThreadPoolMediator
	 */
	public function addListener(ListenerInterface $listener): self
	{
		$this->mediator->addListener($listener);

		return $this;
	}

	/**
	 * @param ListenerInterface $listener
	 * @return AbstractThreadPoolMediator
	 */
	public function removeListener(ListenerInterface $listener): self
	{
		$this->mediator->removeListener($listener);

		return $this;
	}

	/**
	 * @param string              $eventName
	 * @param AbstractThread|null $thread
	 */
	protected function notify(string $eventName, ?AbstractThread $thread = null)
	{
		$this->getMediator()->notify(EventPoolFactory::create($eventName, $this, $thread));
	}

}