WyriHaximus\React\ChildProcess\Messenger\OutstandingCall

Complexity

Total Complexity

8

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

69.23%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getUniqid()	0	4	1
A	getDeferred()	0	4	1
A	resolve()	0	7	1
A	__construct()	0	15	3
A	progress()	0	7	1
A	reject()	0	7	1

<?php

namespace WyriHaximus\React\ChildProcess\Messenger;

use React\Promise\Deferred;

class OutstandingCall
{
    /**
     * @var string
     */
    protected $uniqid;

    /**
     * @var Deferred
     */
    protected $deferred;

    /**
     * @var callable
     */
    protected $cleanup;

    /**
     * @param string   $uniqid
     * @param callable $canceller
     */
    public function __construct($uniqid, callable $canceller = null, callable $cleanup = null)
    {
        if ($canceller !== null) {
            $canceller = \Closure::bind($canceller, $this, 'WyriHaximus\React\ChildProcess\Messenger\OutstandingCall');
        }

        $this->uniqid = $uniqid;
        $this->deferred = new Deferred($canceller);

        if (!is_callable($cleanup)) {
            $cleanup = function () {
            };
        }
        $this->cleanup = $cleanup;
    }

    /**
     * @return mixed
     */
    public function getUniqid()
    {
        return $this->uniqid;
    }

    /**
     * @return Deferred
     */
    public function getDeferred()
    {
        return $this->deferred;
    }

    /**
     * @param mixed $value
     */
    public function resolve($value)
    {
        $cleanup = $this->cleanup;
        $cleanup($this);

        return $this->deferred->resolve($value);
    }

    /**
     * @param mixed $value
     */
    public function progress($value)
    {
        $cleanup = $this->cleanup;
        $cleanup($this);

        return $this->deferred->progress($value);

The method React\Promise\Deferred::progress() has been deprecated with message: 2.2.0

    }

    /**
     * @param mixed $value
     */
    public function reject($value)
    {
        $cleanup = $this->cleanup;
        $cleanup($this);

        return $this->deferred->reject($value);
    }
}