Dazzle\Event\AsyncEventEmitterTrait

Complexity

Total Complexity

4

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	attachOnListener()	0	9	1
A	attachOnceListener()	0	11	1
A	attachTimesListener()	0	16	2

<?php

namespace Dazzle\Event;

use Dazzle\Loop\LoopAwareTrait;

trait AsyncEventEmitterTrait
{
    use LoopAwareTrait;
    use BaseEventEmitterTrait;

    /**
     * @see BaseEventEmitterTrait::attachOnListener
     */
    protected function attachOnListener($pointer, $event, callable $listener)

The parameter $pointer is not used and could be removed.

The parameter $event is not used and could be removed.

    {
        return function() use($listener) {
            $args = func_get_args();
            $this->getLoop()->onTick(function() use($listener, $args) {
                $listener(...$args);
            });
        };
    }

    /**
     * @see BaseEventEmitterTrait::attachOnceListener
     */
    protected function attachOnceListener($pointer, $event, callable $listener)
    {
        return function() use($listener, $event, $pointer) {
            unset($this->eventListeners[$event][$pointer]);

            $args = func_get_args();
            $this->getLoop()->onTick(function() use($listener, $args) {
                $listener(...$args);
            });
        };
    }

    /**
     * @see BaseEventEmitterTrait::attachTimesListener
     */
    protected function attachTimesListener($pointer, $event, $limit, callable $listener)
    {
        $emitter = $this;
        return function() use($emitter, $listener, $event, $pointer, &$limit) {
            if (--$limit === 0)
            {
                unset($limit);
                unset($emitter->eventListeners[$event][$pointer]);
            }

            $args = func_get_args();
            $this->getLoop()->onTick(function() use($listener, $args) {
                $listener(...$args);
            });
        };
    }
}