PEIP\ABS\Pipe\EventPipe

Complexity

Total Complexity

5

Size/Duplication

Total Lines	43
Duplicated Lines	32.56 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	3
Bugs	3	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	doListen()	7	7	2
A	doUnlisten()	7	7	2
A	doGetConnected()	0	4	1

<?php

namespace PEIP\ABS\Pipe;

/*
 * This file is part of the PEIP package.
 * (c) 2009-2016 Timo Michna <timomichna/yahoo.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

/*
 * PEIP\ABS\Pipe\EventPipe
 * Abstract base class for all event handling Pipes.
 *
 * @author Timo Michna <timomichna/yahoo.de>
 * @package PEIP
 * @subpackage pipe
 * @extends \PEIP\Pipe\Pipe
 * @abstract
 * @implements \PEIP\INF\Event\Connectable, \PEIP\INF\Channel\SubscribableChannel, \PEIP\INF\Channel\Channel, \PEIP\INF\Handler\Handler, \PEIP\INF\Message\MessageBuilder
 */

use PEIP\Pipe\Pipe;

abstract class EventPipe extends \PEIP\Pipe\Pipe
{
    protected $connections = [];

    /**
     * Connects the event-pipe to a given \PEIP\INF\Event\Connectable instance by listening
     * to a given event on the connectable.
     *
     * @param string                      $eventName   name of the event to listen to
     * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to
     */
    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable)

This method seems to be duplicated in your project.

    {
        if (!$connectable->hasListener($eventName, $this)) {

The method hasListener() does not exist on PEIP\INF\Event\Connectable. Did you maybe mean hasListeners()?

            $connectable->connect($eventName, $this);
            $this->connections[spl_object_hash($connectable)] = $connectable;
        }
    }

    /**
     * Disonnects the event-pipe from listening to a given event on a \PEIP\INF\Event\Connectable instance.
     *
     * @param string                      $eventName   name of the event to unlisten
     * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to
     */
    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable)

This method seems to be duplicated in your project.

    {
        if (!$connectable->hasListener($eventName, $this)) {

The method hasListener() does not exist on PEIP\INF\Event\Connectable. Did you maybe mean hasListeners()?

            $connectable->disconnect($eventName, $this);
            unset($this->connections[spl_object_hash($connectable)]);
        }
    }

    /**
     * Returns the instances of \PEIP\INF\Event\Connectable the event-pipe is litening to.
     *
     * @return array array of \PEIP\INF\Event\Connectable instances
     */
    public function doGetConnected()
    {
        return array_values($this->connections);
    }
}