AsyncSockets\RequestExecutor\RemoveFinishedSocketsEventHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	invokeEvent()	0	17	4

<?php
/**
 * Async sockets
 *
 * @copyright Copyright (c) 2015-2017, Efimov Evgenij <edefimov.it@gmail.com>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */
namespace AsyncSockets\RequestExecutor;

use AsyncSockets\Event\Event;
use AsyncSockets\Event\EventType;
use AsyncSockets\Socket\SocketInterface;

/**
 * Class RemoveFinishedSocketsEventHandler
 */
class RemoveFinishedSocketsEventHandler implements EventHandlerInterface
{
    /**
     * Target handler
     *
     * @var EventHandlerInterface
     */
    private $handler;

    /**
     * RemoveFinishedSocketsEventHandler constructor.
     *
     * @param EventHandlerInterface $handler Original event handler
     */
    public function __construct(EventHandlerInterface $handler = null)
    {
        $this->handler = $handler;
    }

    /** {@inheritdoc} */
    public function invokeEvent(
        Event $event,
        RequestExecutorInterface $executor,
        SocketInterface $socket,
        ExecutionContext $context
    ) {
        if ($this->handler) {
            $this->handler->invokeEvent($event, $executor, $socket, $context);
        }

        if ($event->getType() === EventType::FINALIZE) {
            $bag = $event->getExecutor()->socketBag();
            if ($bag->hasSocket($socket)) {
                $bag->removeSocket($socket);
            }
        }
    }
}