AbstractListenerResolver::subscribe()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 5
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 3
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 5
ccs 3
cts 3
cp 1
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 3
nc 1
nop 2
crap 1
1
<?php
2
/**
3
 * @package narrator
4
 */
5
6
namespace Mleko\Narrator\ListenerResolver;
7
8
9
use Mleko\Narrator\Listener;
10
use Mleko\Narrator\ListenerResolver;
11
use Mleko\Narrator\Subscription;
12
13
abstract class AbstractListenerResolver implements ListenerResolver
14
{
15
    /** @var Listener[][] */
16
    protected $listeners = [];
17
18
    /**
19
     * @param string $eventName
20
     * @param Listener $listener
21
     * @return Subscription
22
     */
23 10
    public function subscribe($eventName, Listener $listener)
24
    {
25 10
        $this->listeners[$eventName][] = $listener;
26 10
        return new Subscription($eventName, $listener, $this);
27
    }
28
29
    /**
30
     * @param string $eventName
31
     * @param Listener $listener
32
     * @return bool
33
     */
34 7
    public function unsubscribe($eventName, Listener $listener)
35
    {
36 7
        $eventListeners = array_key_exists($eventName, $this->listeners) ? $this->listeners[$eventName] : [];
37 7
        foreach ($eventListeners as $key => $eventListener) {
38 7
            if ($listener === $eventListener) {
39 7
                unset($this->listeners[$eventName][$key]);
40 7
                return true;
41
            }
42 3
        }
43 3
        return false;
44
    }
45
}
46