SimpleEventBus::publish() - Code Metrics - cultuurnet/udb3-php - Measure and Improve Code Quality continuously with Scrutinizer

SimpleEventBus::publish() A
last analyzed 2021-01-13 15:28 UTC

↳ Parent: SimpleEventBus

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	9
rs	9.9666
c	0
b	0
f	0
cc	2
nc	2
nop	1

<?php
/**
 * @file
 */

namespace CultuurNet\UDB3;

use Broadway\Domain\DomainEventStreamInterface;

/**
 * Class SimpleEventBus
 *
 * Extension of Broadway's SimpleEventBus with a configurable callback to be
 * executed before the first message is published. This callback can be used to
 * subscribe listeners.
 */
class SimpleEventBus extends \Broadway\EventHandling\SimpleEventBus
{
    private $first = true;

    /**
     * @var null|callable
     */
    private $beforeFirstPublicationCallback;

    /**
     * @param callable $callback
     */
    public function beforeFirstPublication($callback)
    {
        $this->beforeFirstPublicationCallback = $callback;
    }

    private function callBeforeFirstPublicationCallback()
    {
        if ($this->beforeFirstPublicationCallback) {
            $callback = $this->beforeFirstPublicationCallback;
            $callback($this);
        }
    }

    public function publish(DomainEventStreamInterface $domainMessages)
    {
        if ($this->first) {
            $this->first = false;
            $this->callBeforeFirstPublicationCallback();
        }

        parent::publish($domainMessages);
    }
}


1			<?php
2			/**
3			* @file
4			*/
5
6			namespace CultuurNet\UDB3;
7
8			use Broadway\Domain\DomainEventStreamInterface;
9
10			/**
11			* Class SimpleEventBus
12			*
13			* Extension of Broadway's SimpleEventBus with a configurable callback to be
14			* executed before the first message is published. This callback can be used to
15			* subscribe listeners.
16			*/
17			class SimpleEventBus extends \Broadway\EventHandling\SimpleEventBus
18			{
19			private $first = true;
20
21			/**
22			* @var null\|callable
23			*/
24			private $beforeFirstPublicationCallback;
25
26			/**
27			* @param callable $callback
28			*/
29			public function beforeFirstPublication($callback)
30			{
31			$this->beforeFirstPublicationCallback = $callback;
32			}
33
34			private function callBeforeFirstPublicationCallback()
35			{
36			if ($this->beforeFirstPublicationCallback) {
37			$callback = $this->beforeFirstPublicationCallback;
38			$callback($this);
39			}
40			}
41
42			public function publish(DomainEventStreamInterface $domainMessages)
43			{
44			if ($this->first) {
45			$this->first = false;
46			$this->callBeforeFirstPublicationCallback();
47			}
48
49			parent::publish($domainMessages);
50			}
51			}
52

cultuurnet / udb3-php

SimpleEventBus::publish() A last analyzed 2021-01-13 15:28 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SimpleEventBus::publish() A
last analyzed 2021-01-13 15:28 UTC