EventQueueWorker::start() - Code Metrics - Inspection of "Merge pull request #6 from jellyfishphp/feature/ev..." - jellyfishphp/jellyfish - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( c2ba48...1fd225 )

by Markus

created 2019-01-08 15:03 UTC

EventQueueWorker::start() A

↳ Parent: EventQueueWorker

Complexity

Conditions	4
Paths	4

Size

Total Lines	8
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	5
dl	0
loc	8
rs	10
c	0
b	0
f	0
cc	4
nc	4
nop	0

<?php

namespace Jellyfish\Event;

class EventQueueWorker implements EventQueueWorkerInterface
{
    /**
     * @var \Jellyfish\Event\EventQueueConsumerInterface
     */
    protected $eventQueueConsumer;
    /**
     * @var \Jellyfish\Event\EventDispatcherInterface
     */
    protected $eventDispatcher;

    /**
     * @param \Jellyfish\Event\EventDispatcherInterface $eventDispatcher
     * @param \Jellyfish\Event\EventQueueConsumerInterface $eventQueueConsumer
     */
    public function __construct(
        EventDispatcherInterface $eventDispatcher,
        EventQueueConsumerInterface $eventQueueConsumer
    ) {
        $this->eventDispatcher = $eventDispatcher;
        $this->eventQueueConsumer = $eventQueueConsumer;
    }

    /**
     * @return void
     */
    public function start(): void
    {
        $listeners = $this->eventDispatcher->getListeners(EventListenerInterface::TYPE_ASYNC);

        while (true) {
            foreach ($listeners as $eventName => $listenersPerEvent) {
                foreach ($listenersPerEvent as $listenerIdentifier => $listener) {
                    $this->eventQueueConsumer->dequeueEventAsProcess($eventName, $listenerIdentifier);
                }
            }
        }
    }
}


1			<?php
2
3			namespace Jellyfish\Event;
4
5			class EventQueueWorker implements EventQueueWorkerInterface
6			{
7			/**
8			* @var \Jellyfish\Event\EventQueueConsumerInterface
9			*/
10			protected $eventQueueConsumer;
11			/**
12			* @var \Jellyfish\Event\EventDispatcherInterface
13			*/
14			protected $eventDispatcher;
15
16			/**
17			* @param \Jellyfish\Event\EventDispatcherInterface $eventDispatcher
18			* @param \Jellyfish\Event\EventQueueConsumerInterface $eventQueueConsumer
19			*/
20			public function __construct(
21			EventDispatcherInterface $eventDispatcher,
22			EventQueueConsumerInterface $eventQueueConsumer
23			) {
24			$this->eventDispatcher = $eventDispatcher;
25			$this->eventQueueConsumer = $eventQueueConsumer;
26			}
27
28			/**
29			* @return void
30			*/
31			public function start(): void
32			{
33			$listeners = $this->eventDispatcher->getListeners(EventListenerInterface::TYPE_ASYNC);
34
35			while (true) {
36			foreach ($listeners as $eventName => $listenersPerEvent) {
37			foreach ($listenersPerEvent as $listenerIdentifier => $listener) {
38			$this->eventQueueConsumer->dequeueEventAsProcess($eventName, $listenerIdentifier);
39			}
40			}
41			}
42			}
43			}
44

jellyfishphp / jellyfish

Push — master ( c2ba48...1fd225 )

EventQueueWorker::start() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like