DeferredProvider::dispatchEvents() - Code Metrics - Inspection of "Add deferred provider" - yiisoft/event-dispatcher - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#30)

unknown

created 2020-07-23 18:25 UTC

DeferredProvider::dispatchEvents() A

↳ Parent: DeferredProvider

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

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

<?php

declare(strict_types=1);

namespace Yiisoft\EventDispatcher\Provider;

use Psr\EventDispatcher\EventDispatcherInterface;
use Psr\EventDispatcher\ListenerProviderInterface;

/**
 * DeferredProvider is a listener provider that allows you to perform deferred
 * events
 */
final class DeferredProvider implements ListenerProviderInterface
{
    private EventDispatcherInterface $dispatcher;
    private bool                     $deferEvents = false;
    private array                    $events = [];

    public function __construct(EventDispatcherInterface $dispatcher)
    {
        $this->dispatcher = $dispatcher;
    }

    public function getListenersForEvent(object $event): iterable
    {
        if ($this->deferEvents) {
            yield fn($event) => $this->addEvent($event);
        } else {
            yield fn($event) => $this->dispatchEvent($event);
        }
    }

    public function deferEvents(): void
    {
        $this->deferEvents = true;
    }

    public function clearEvents(): void
    {
        $this->events = [];
    }

    public function dispatchEvents(): array
    {
        $events = $this->events;
        $this->clearEvents();
        $this->deferEvents = false;
        $dispatchedEvents = [];

        foreach ($events as $event) {
            $dispatchedEvents[] = $this->dispatchEvent($event);
        }

        return $dispatchedEvents;
    }

    private function addEvent(object $event): void
    {
        $this->events[] = $event;
    }

    private function dispatchEvent(object $event): object
    {
        return $this->dispatcher->dispatch($event);
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Yiisoft\EventDispatcher\Provider;
6
7			use Psr\EventDispatcher\EventDispatcherInterface;
8			use Psr\EventDispatcher\ListenerProviderInterface;
9
10			/**
11			* DeferredProvider is a listener provider that allows you to perform deferred
12			* events
13			*/
14			final class DeferredProvider implements ListenerProviderInterface
15			{
16			private EventDispatcherInterface $dispatcher;
17			private bool $deferEvents = false;
18			private array $events = [];
19
20			public function __construct(EventDispatcherInterface $dispatcher)
21			{
22			$this->dispatcher = $dispatcher;
23			}
24
25			public function getListenersForEvent(object $event): iterable
26			{
27			if ($this->deferEvents) {
28			yield fn($event) => $this->addEvent($event);
29			} else {
30			yield fn($event) => $this->dispatchEvent($event);
31			}
32			}
33
34			public function deferEvents(): void
35			{
36			$this->deferEvents = true;
37			}
38
39			public function clearEvents(): void
40			{
41			$this->events = [];
42			}
43
44			public function dispatchEvents(): array
45			{
46			$events = $this->events;
47			$this->clearEvents();
48			$this->deferEvents = false;
49			$dispatchedEvents = [];
50
51			foreach ($events as $event) {
52			$dispatchedEvents[] = $this->dispatchEvent($event);
53			}
54
55			return $dispatchedEvents;
56			}
57
58			private function addEvent(object $event): void
59			{
60			$this->events[] = $event;
61			}
62
63			private function dispatchEvent(object $event): object
64			{
65			return $this->dispatcher->dispatch($event);
66			}
67			}
68

yiisoft / event-dispatcher

Pull Request — master (#30)

DeferredProvider::dispatchEvents() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like