promise/src/Deferred.php at c4e614538c0a02e4b1ac0db1db47c8075e7ff3e3 · clue-labs/promise · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
<?php

namespace React\Promise;

final class Deferred
{
    /** @var Promise */
    private $promise;

    /** @var callable */
    private $resolveCallback;

    /** @var callable */
    private $rejectCallback;

    public function __construct(callable $canceller = null)
    {
        $this->promise = new Promise(function ($resolve, $reject): void {
            $this->resolveCallback = $resolve;
            $this->rejectCallback  = $reject;
        }, $canceller);
    }

    public function promise(): PromiseInterface
    {
        return $this->promise;
    }

    /**
     * @param mixed $value
     */
    public function resolve($value): void
    {
        ($this->resolveCallback)($value);
    }

    public function reject(\Throwable $reason): void
    {
        ($this->rejectCallback)($reason);
    }
}