SimpleEventBus::publish() - Code Metrics - SmoothPhp/CQRS-ES-Framework - Measure and Improve Code Quality continuously with Scrutinizer

SimpleEventBus::publish() A
last analyzed 2018-07-17 11:14 UTC

↳ Parent: SimpleEventBus

Complexity

Conditions	4
Paths	6

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	4

Importance

Changes

Metric	Value
dl	0
loc	12
ccs	7
cts	7
cp	1
c	0
b	0
f	0
cc	4
nc	6
nop	1
crap	4
rs	9.8666

<?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 <[email protected]>
 */
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);
            }
        }
    }
}

1		<?php
2		namespace SmoothPhp\EventBus;
3
4		use SmoothPhp\Contracts\Domain\DomainEventStream;
5		use SmoothPhp\Contracts\Domain\DomainMessage;
6		use SmoothPhp\Contracts\EventBus\EventBus;
7		use SmoothPhp\Contracts\EventBus\EventListener;
8
9		/**
10		* Class SimpleEventBus
11		* @package SmoothPhp\EventBus
12		* @author Simon Bennett <[email protected]>
13		*/
14		final class SimpleEventBus implements EventBus
15		{
16		/**
17		* @var EventListener[]
18		*/
19		private $eventListeners = [];
20
21		/**
22		* @var DomainMessage[]
23		*/
24		private $queue = [];
25
26		/**
27		* @param $eventListener
28		* @return mixed
29		*/
30	3	public function subscribe(EventListener $eventListener)
31		{
32	3	$this->eventListeners[] = $eventListener;
33	3	}
34
35		/**
36		* @param DomainEventStream $domainEventStream
37		* @return void
38		*/
39	6	public function publish(DomainEventStream $domainEventStream)
40		{
41	6	foreach ($domainEventStream as $domainMessage) {
42	3	$this->queue[] = $domainMessage;
43		}
44
45	6	while ($domainMessage = array_shift($this->queue)) {
46	3	foreach ($this->eventListeners as $eventListener) {
47	3	$eventListener->handle($domainMessage);
48		}
49		}
50		}
51		}

SmoothPhp / CQRS-ES-Framework

GitHub Access Token became invalid

SimpleEventBus::publish() A last analyzed 2018-07-17 11:14 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

SimpleEventBus::publish() A
last analyzed 2018-07-17 11:14 UTC