SmoothPhp\EventBus\SimpleEventBus

Complexity

Total Complexity

5

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	subscribe()	0	4	1
A	publish()	0	12	4

<?php
namespace SmoothPhp\EventBus;

use SmoothPhp\Contracts\Domain\DomainEventStream;
use SmoothPhp\Contracts\Domain\DomainMessage;
use SmoothPhp\Contracts\EventBus\EventBus;
use SmoothPhp\Contracts\EventBus\EventListener;

/**
 * Class SimpleEventBus
 * @package SmoothPhp\EventBus
 * @author Simon Bennett <simon@bennett.im>
 */
final class SimpleEventBus implements EventBus
{
    /**
     * @var EventListener[]
     */
    private $eventListeners = [];

    /**
     * @var DomainMessage[]
     */
    private $queue = [];

    /**
     * @param $eventListener
     * @return mixed
     */
    public function subscribe(EventListener $eventListener)
    {
        $this->eventListeners[] = $eventListener;
    }

    /**
     * @param DomainEventStream $domainEventStream
     * @return void
     */
    public function publish(DomainEventStream $domainEventStream)
    {
        foreach ($domainEventStream as $domainMessage) {
            $this->queue[] = $domainMessage;
        }

        while ($domainMessage = array_shift($this->queue)) {
            foreach ($this->eventListeners as $eventListener) {
                $eventListener->handle($domainMessage);
            }
        }
    }
}