Mleko\Narrator\BasicEventBus

Complexity

Total Complexity

7

Size/Duplication

Total Lines	53
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	9	3
A	emit()	0	7	2
A	subscribe()	0	4	1
A	unsubscribe()	0	4	1

<?php
/**
 * @package narrator
 */


namespace Mleko\Narrator;


class BasicEventBus implements EventBus
{

    /** @var ListenerResolver */
    private $listenerResolver;

    /**
     * SimpleEventBus constructor.
     * @param ListenerResolver $listenerResolver
     * @param Listener[][] $listeners
     */
    public function __construct(ListenerResolver $listenerResolver, array $listeners = [])
    {
        $this->listenerResolver = $listenerResolver;
        foreach ($listeners as $eventName => $eventListeners) {
            foreach ($eventListeners as $listener) {
                $this->subscribe($eventName, $listener);
            }
        }
    }

    /**
     * @param object $event
     * @return void
     */
    public function emit($event)
    {
        $resolvedListeners = $this->listenerResolver->getEventListeners($event, $this);
        foreach ($resolvedListeners as $resolvedListener) {
            $resolvedListener->emit($event);
        }
    }

    /**
     * @param string $eventName
     * @param Listener $listener
     * @return Subscription
     */
    public function subscribe($eventName, Listener $listener)
    {
        return $this->listenerResolver->subscribe($eventName, $listener);
    }

    /**
     * @param string $eventName
     * @param Listener $listener
     * @return bool
     */
    public function unsubscribe($eventName, Listener $listener)
    {
        return $this->listenerResolver->unsubscribe($eventName, $listener);
    }
}