PromiseTest.php

Go to the documentation of this file.

<?php
 
namespace Sabre\Event;
 
class PromiseTest extends \PHPUnit_Framework_TestCase {
 
    function testSuccess() {
 
        $finalValue = 0;
        $promise = new Promise();
        $promise->fulfill(1);
 
        $promise->then(function($value) use (&$finalValue) {
            $finalValue = $value + 2;
        });
        Loop\run();
 
        $this->assertEquals(3, $finalValue);
 
    }
 
    function testFail() {
 
        $finalValue = 0;
        $promise = new Promise();
        $promise->reject(1);
 
        $promise->then(null, function($value) use (&$finalValue) {
            $finalValue = $value + 2;
        });
        Loop\run();
 
        $this->assertEquals(3, $finalValue);
 
    }
 
    function testChain() {
 
        $finalValue = 0;
        $promise = new Promise();
        $promise->fulfill(1);
 
        $promise->then(function($value) use (&$finalValue) {
            $finalValue = $value + 2;
            return $finalValue;
        })->then(function($value) use (&$finalValue) {
            $finalValue = $value + 4;
            return $finalValue;
        });
        Loop\run();
 
        $this->assertEquals(7, $finalValue);
 
    }
    function testChainPromise() {
 
        $finalValue = 0;
        $promise = new Promise();
        $promise->fulfill(1);
 
        $subPromise = new Promise();
 
        $promise->then(function($value) use ($subPromise) {
            return $subPromise;
        })->then(function($value) use (&$finalValue) {
            $finalValue = $value + 4;
            return $finalValue;
        });
 
        $subPromise->fulfill(2);
        Loop\run();
 
        $this->assertEquals(6, $finalValue);
 
    }
 
    function testPendingResult() {
 
        $finalValue = 0;
        $promise = new Promise();
 
        $promise->then(function($value) use (&$finalValue) {
            $finalValue = $value + 2;
        });
 
        $promise->fulfill(4);
        Loop\run();
 
        $this->assertEquals(6, $finalValue);
 
    }
 
    function testPendingFail() {
 
        $finalValue = 0;
        $promise = new Promise();
 
        $promise->then(null, function($value) use (&$finalValue) {
            $finalValue = $value + 2;
        });
 
        $promise->reject(4);
        Loop\run();
 
        $this->assertEquals(6, $finalValue);
 
    }
 
    function testExecutorSuccess() {
 
        $promise = (new Promise(function($success, $fail) {
 
            $success('hi');
 
        }))->then(function($result) use (&$realResult) {
 
            $realResult = $result;
 
        });
        Loop\run();
 
        $this->assertEquals('hi', $realResult);
 
    }
 
    function testExecutorFail() {
 
        $promise = (new Promise(function($success, $fail) {
 
            $fail('hi');
 
        }))->then(function($result) use (&$realResult) {
 
            $realResult = 'incorrect';
 
        }, function($reason) use (&$realResult) {
 
            $realResult = $reason;
 
        });
        Loop\run();
 
        $this->assertEquals('hi', $realResult);
 
    }
 
    function testFulfillTwice() {
 
        $promise = new Promise();
        $promise->fulfill(1);
        $promise->fulfill(1);
 
    }
 
    function testRejectTwice() {
 
        $promise = new Promise();
        $promise->reject(1);
        $promise->reject(1);
 
    }
 
    function testFromFailureHandler() {
 
        $ok = 0;
        $promise = new Promise();
        $promise->otherwise(function($reason) {
 
            $this->assertEquals('foo', $reason);
            throw new \Exception('hi');
 
        })->then(function() use (&$ok) {
 
            $ok = -1;
 
        }, function() use (&$ok) {
 
            $ok = 1;
 
        });
 
        $this->assertEquals(0, $ok);
        $promise->reject('foo');
        Loop\run();
 
        $this->assertEquals(1, $ok);
 
    }
 
    function testAll() {
 
        $promise1 = new Promise();
        $promise2 = new Promise();
 
        $finalValue = 0;
        Promise::all([$promise1, $promise2])->then(function($value) use (&$finalValue) {
 
            $finalValue = $value;
 
        });
 
        $promise1->fulfill(1);
        Loop\run();
        $this->assertEquals(0, $finalValue);
 
        $promise2->fulfill(2);
        Loop\run();
        $this->assertEquals([1, 2], $finalValue);
 
    }
 
    function testAllReject() {
 
        $promise1 = new Promise();
        $promise2 = new Promise();
 
        $finalValue = 0;
        Promise::all([$promise1, $promise2])->then(
            function($value) use (&$finalValue) {
                $finalValue = 'foo';
                return 'test';
            },
            function($value) use (&$finalValue) {
                $finalValue = $value;
            }
        );
 
        $promise1->reject(1);
        Loop\run();
        $this->assertEquals(1, $finalValue);
        $promise2->reject(2);
        Loop\run();
        $this->assertEquals(1, $finalValue);
 
    }
 
    function testAllRejectThenResolve() {
 
        $promise1 = new Promise();
        $promise2 = new Promise();
 
        $finalValue = 0;
        Promise::all([$promise1, $promise2])->then(
            function($value) use (&$finalValue) {
                $finalValue = 'foo';
                return 'test';
            },
            function($value) use (&$finalValue) {
                $finalValue = $value;
            }
        );
 
        $promise1->reject(1);
        Loop\run();
        $this->assertEquals(1, $finalValue);
        $promise2->fulfill(2);
        Loop\run();
        $this->assertEquals(1, $finalValue);
 
    }
 
    function testRace() {
 
        $promise1 = new Promise();
        $promise2 = new Promise();
 
        $finalValue = 0;
        Promise\race([$promise1, $promise2])->then(
            function($value) use (&$finalValue) {
                $finalValue = $value;
            },
            function($value) use (&$finalValue) {
                $finalValue = $value;
            }
        );
 
        $promise1->fulfill(1);
        Loop\run();
        $this->assertEquals(1, $finalValue);
        $promise2->fulfill(2);
        Loop\run();
        $this->assertEquals(1, $finalValue);
 
    }
 
    function testRaceReject() {
 
        $promise1 = new Promise();
        $promise2 = new Promise();
 
        $finalValue = 0;
        Promise\race([$promise1, $promise2])->then(
            function($value) use (&$finalValue) {
                $finalValue = $value;
            },
            function($value) use (&$finalValue) {
                $finalValue = $value;
            }
        );
 
        $promise1->reject(1);
        Loop\run();
        $this->assertEquals(1, $finalValue);
        $promise2->reject(2);
        Loop\run();
        $this->assertEquals(1, $finalValue);
 
    }
 
    function testWaitResolve() {
 
        $promise = new Promise();
        Loop\nextTick(function() use ($promise) {
            $promise->fulfill(1);
        });
        $this->assertEquals(
            1,
            $promise->wait()
        );
 
    }
 
    function testWaitWillNeverResolve() {
 
        $promise = new Promise();
        $promise->wait();
 
    }
 
    function testWaitRejectedException() {
 
        $promise = new Promise();
        Loop\nextTick(function() use ($promise) {
            $promise->reject(new \OutOfBoundsException('foo'));
        });
        try {
            $promise->wait();
            $this->fail('We did not get the expected exception');
        } catch (\Exception $e) {
            $this->assertInstanceOf('OutOfBoundsException', $e);
            $this->assertEquals('foo', $e->getMessage());
        }
 
    }
 
    function testWaitRejectedScalar() {
 
        $promise = new Promise();
        Loop\nextTick(function() use ($promise) {
            $promise->reject('foo');
        });
        try {
            $promise->wait();
            $this->fail('We did not get the expected exception');
        } catch (\Exception $e) {
            $this->assertInstanceOf('Exception', $e);
            $this->assertEquals('foo', $e->getMessage());
        }
 
    }
 
    function testWaitRejectedNonScalar() {
 
        $promise = new Promise();
        Loop\nextTick(function() use ($promise) {
            $promise->reject([]);
        });
        try {
            $promise->wait();
            $this->fail('We did not get the expected exception');
        } catch (\Exception $e) {
            $this->assertInstanceOf('Exception', $e);
            $this->assertEquals('Promise was rejected with reason of type: array', $e->getMessage());
        }
 
    }
}