Dazzle\Channel\Record\RequestRecord

Complexity

Total Complexity

13

Size/Duplication

Total Lines	141
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	4
A	__destruct()	0	8	1
A	getPid()	0	4	1
A	onSuccess()	0	4	1
A	onFailure()	0	4	1
A	onCancel()	0	4	1
A	getTimeout()	0	4	1
A	resolve()	0	5	1
A	reject()	0	5	1
A	cancel()	0	5	1

<?php

namespace Dazzle\Channel\Record;

use Dazzle\Throwable\ThrowableProxy;
use Error;
use Exception;

class RequestRecord
{
    /**
     * @var string
     */
    public $pid;

    /**
     * @var callable
     */
    public $success;

    /**
     * @var callable
     */
    public $failure;

    /**
     * @var callable
     */
    public $cancel;

    /**
     * @var float
     */
    public $timeout;

    /**
     * @param string $pid
     * @param callable|null $success
     * @param callable|null $failure
     * @param callable|null $cancel
     * @param float $timeout
     */
    public function __construct($pid, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
    {
        $this->pid     = $pid;
        $this->success = ($success !== null) ? $success : function() {};
        $this->failure = ($failure !== null) ? $failure : function() {};
        $this->cancel  = ($cancel !== null)  ? $cancel  : function() {};
        $this->timeout = $timeout;
    }

    /**
     *
     */
    public function __destruct()
    {
        unset($this->pid);
        unset($this->success);
        unset($this->failure);
        unset($this->cancel);
        unset($this->timeout);
    }

    /**
     * Return protocol ID.
     *
     * @return string
     */
    public function getPid()
    {
        return $this->pid;
    }

    /**
     * Return success handler.
     *
     * @return callable
     */
    public function onSuccess()
    {
        return $this->success;
    }

    /**
     * Return failure handler.
     *
     * @return callable
     */
    public function onFailure()
    {
        return $this->failure;
    }

    /**
     * Return cancellation handler.
     *
     * @return callable
     */
    public function onCancel()
    {
        return $this->cancel;
    }

    /**
     * Return timeout.
     *
     * @return float
     */
    public function getTimeout()
    {
        return $this->timeout;
    }

    /**
     * Resolve Request calling success handler.
     *
     * @param mixed $value
     * @return mixed
     */
    public function resolve($value)
    {
        $callback = $this->onSuccess();
        return $callback($value);
    }

    /**
     * Reject Request calling failure handler.
     *
     * @param Error|Exception|ThrowableProxy $ex
     * @return mixed
     */
    public function reject($ex)
    {
        $callback = $this->onFailure();
        return $callback($ex);
    }

    /**
     * Cancel Request calling cancellation handler.
     *
     * @param Error|Exception|ThrowableProxy $ex
     * @return mixed
     */
    public function cancel($ex)
    {
        $callback = $this->onCancel();
        return $callback($ex);
    }
}