AsyncSockets\RequestExecutor\LibEvent\LeEvent

Complexity

Total Complexity

8

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__destruct()	0	4	1
A	getTimeout()	0	4	1
A	getHandle()	0	4	1
A	fire()	0	4	1
A	destroy()	0	8	2
A	__construct()	0	7	1
A	getRequestDescriptor()	0	4	1

<?php
/**
 * Async sockets
 *
 * @copyright Copyright (c) 2015-2016, 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\LibEvent;

use AsyncSockets\RequestExecutor\Metadata\RequestDescriptor;

/**
 * Class LeEvent
 */
class LeEvent
{
    /**
     * Libevent event handle
     *
     * @var resource
     */
    private $handle;

    /**
     * Callback object
     *
     * @var LeCallbackInterface
     */
    private $callback;

    /**
     * RequestDescriptor
     *
     * @var RequestDescriptor
     */
    private $requestDescriptor;

    /**
     * Timeout for event
     *
     * @var int|null
     */
    private $timeout;

    /**
     * LeEvent constructor.
     *
     * @param LeCallbackInterface $callback Callback object
     * @param RequestDescriptor   $requestDescriptor Request descriptor object
     * @param int|null            $timeout Timeout for event
     */
    public function __construct(LeCallbackInterface $callback, RequestDescriptor $requestDescriptor, $timeout)
    {
        $this->handle            = event_new();
        $this->callback          = $callback;
        $this->requestDescriptor = $requestDescriptor;
        $this->timeout           = $timeout;
    }

    /**
     * Destructor
     */
    public function __destruct()
    {
        $this->destroy();
    }

    /**
     * Return Timeout
     *
     * @return int|null
     */
    public function getTimeout()
    {
        return $this->timeout;
    }

    /**
     * Return Handle
     *
     * @return resource
     */
    public function getHandle()
    {
        return $this->handle;
    }

    /**
     * Return RequestDescriptor
     *
     * @return RequestDescriptor
     */
    public function getRequestDescriptor()
    {
        return $this->requestDescriptor;
    }

    /**
     * Fire event
     *
     * @param string $eventType Type of event, one of LeCallbackInterface::EVENT_* consts
     *
     * @return void
     */
    public function fire($eventType)
    {
        $this->callback->onEvent($this->requestDescriptor, $eventType);
    }

    /**
     * Destroy event handle
     *
     * @return void
     */
    private function destroy()
    {
        if ($this->handle) {
            event_del($this->handle);
            event_free($this->handle);
            $this->handle = null;
        }
    }
}