EventProviderTrait::aggregateEventsFrom() - Code Metrics - brenoroosevelt/oni-bus - Measure and Improve Code Quality continuously with Scrutinizer

EventProviderTrait::aggregateEventsFrom() A
last analyzed 2021-04-30 13:30 UTC

↳ Parent: EventProviderTrait

Complexity

Conditions	2
Paths	2

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	2
c	0
b	0
f	0
dl	0
loc	4
rs	10
cc	2
nc	2
nop	1

<?php
declare(strict_types=1);

namespace OniBus\Event;

use Generator;

trait EventProviderTrait
{
    /**
     * @var array
     */
    protected $events = [];

    /**
     * @var array
     */
    protected $aggregateEvents = [];

    public function recordEvent(Event ...$events)
    {
        foreach ($events as $event) {
            $this->events[] = $event;
        }
    }

    public function aggregateEventsFrom(ProvidesEvent ...$eventRecorders)
    {
        foreach ($eventRecorders as $eventRecorder) {
            $this->aggregateEvents[] = $eventRecorder;
        }
    }

    public function pullEventsFrom(ProvidesEvent ...$eventRecorders)
    {
        foreach ($eventRecorders as $eventRecorder) {
            $this->recordEvent(...$eventRecorder->releaseEvents());
        }
    }

    public function releaseEvents(): Generator
    {
        $this->pullEventsFrom(...$this->aggregateEvents);

        while ($event = array_shift($this->events)) {
            yield $event;
        }
    }
}


1			<?php
2			declare(strict_types=1);
3
4			namespace OniBus\Event;
5
6			use Generator;
7
8			trait EventProviderTrait
9			{
10			/**
11			* @var array
12			*/
13			protected $events = [];
14
15			/**
16			* @var array
17			*/
18			protected $aggregateEvents = [];
19
20			public function recordEvent(Event ...$events)
21			{
22			foreach ($events as $event) {
23			$this->events[] = $event;
24			}
25			}
26
27			public function aggregateEventsFrom(ProvidesEvent ...$eventRecorders)
28			{
29			foreach ($eventRecorders as $eventRecorder) {
30			$this->aggregateEvents[] = $eventRecorder;
31			}
32			}
33
34			public function pullEventsFrom(ProvidesEvent ...$eventRecorders)
35			{
36			foreach ($eventRecorders as $eventRecorder) {
37			$this->recordEvent(...$eventRecorder->releaseEvents());
38			}
39			}
40
41			public function releaseEvents(): Generator
42			{
43			$this->pullEventsFrom(...$this->aggregateEvents);
44
45			while ($event = array_shift($this->events)) {
46			yield $event;
47			}
48			}
49			}
50

brenoroosevelt / oni-bus

EventProviderTrait::aggregateEventsFrom() A last analyzed 2021-04-30 13:30 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

EventProviderTrait::aggregateEventsFrom() A
last analyzed 2021-04-30 13:30 UTC