ExecutingSubscribeEventQueue::unsubscribe() - Code Metrics - gpslab/domain-event - Measure and Improve Code Quality continuously with Scrutinizer

ExecutingSubscribeEventQueue::unsubscribe() A
last analyzed 2019-12-22 18:34 UTC

↳ Parent: ExecutingSubscribeEventQueue

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	12
Ratio	100 %

Code Coverage

Tests	6
CRAP Score	2

Importance

Changes

Metric	Value
dl	12
loc	12
c	0
b	0
f	0
ccs	6
cts	6
cp	1
rs	9.8666
cc	2
nc	2
nop	1
crap	2

<?php

/**
 * GpsLab component.
 *
 * @author    Peter Gribanov <[email protected]>
 * @copyright Copyright (c) 2011, Peter Gribanov
 * @license   http://opensource.org/licenses/MIT
 */

namespace GpsLab\Domain\Event\Queue\Subscribe;

use GpsLab\Domain\Event\Event;

class ExecutingSubscribeEventQueue implements SubscribeEventQueue
{
    /**
     * @var callable[]
     */
    private $handlers = [];

    /**
     * Publish event to queue.
     *
     * @param Event $event
     *
     * @return bool
     */
    public function publish(Event $event)
    {
        // absence of a handlers is not a error
        foreach ($this->handlers as $handler) {
            call_user_func($handler, $event);
        }

        return true;
    }

    /**
     * Subscribe on event queue.
     *
     * @param callable $handler
     */
    public function subscribe(callable $handler)
    {
        $this->handlers[] = $handler;
    }

    /**
     * Unsubscribe on event queue.
     *
     * @param callable $handler
     *
     * @return bool
     */
    public function unsubscribe(callable $handler)
    {
        $index = array_search($handler, $this->handlers);

        if ($index === false) {
            return false;
        }

        unset($this->handlers[$index]);

        return true;
    }
}


1			<?php
2
3			/**
4			* GpsLab component.
5			*
6			* @author Peter Gribanov <[email protected]>
7			* @copyright Copyright (c) 2011, Peter Gribanov
8			* @license http://opensource.org/licenses/MIT
9			*/
10
11			namespace GpsLab\Domain\Event\Queue\Subscribe;
12
13			use GpsLab\Domain\Event\Event;
14
15			class ExecutingSubscribeEventQueue implements SubscribeEventQueue
16			{
17			/**
18			* @var callable[]
19			*/
20			private $handlers = [];
21
22			/**
23			* Publish event to queue.
24			*
25			* @param Event $event
26			*
27			* @return bool
28			*/
29	1		public function publish(Event $event)
30			{
31			// absence of a handlers is not a error
32	1		foreach ($this->handlers as $handler) {
33	1		call_user_func($handler, $event);
34			}
35
36	1		return true;
37			}
38
39			/**
40			* Subscribe on event queue.
41			*
42			* @param callable $handler
43			*/
44	1		public function subscribe(callable $handler)
45			{
46	1		$this->handlers[] = $handler;
47	1		}
48
49			/**
50			* Unsubscribe on event queue.
51			*
52			* @param callable $handler
53			*
54			* @return bool
55			*/
56	1	View Code Duplication	public function unsubscribe(callable $handler)
57			{
58	1		$index = array_search($handler, $this->handlers);
59
60	1		if ($index === false) {
61	1		return false;
62			}
63
64	1		unset($this->handlers[$index]);
65
66	1		return true;
67			}
68			}
69

gpslab / domain-event

ExecutingSubscribeEventQueue::unsubscribe() A last analyzed 2019-12-22 18:34 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

ExecutingSubscribeEventQueue::unsubscribe() A
last analyzed 2019-12-22 18:34 UTC