OniBus\Event\EventProviderTrait

Complexity

Total Complexity

8

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	recordEvent()	0	4	2
A	aggregateEventsFrom()	0	4	2
A	releaseEvents()	0	6	2
A	pullEventsFrom()	0	4	2

<?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;
        }
    }
}