1
0
mirror of https://github.com/danog/amp.git synced 2024-11-26 20:15:00 +01:00
amp/test/WaitTest.php
Niklas Keller c12828081f Fix exceptions bubbling from Coroutine::__destruct
This has been an edge case potentially hiding some exceptions. The tests have been refactored to error if the loop has watchers leaking from one test to another test.
2019-05-31 11:38:02 -05:00

101 lines
2.1 KiB
PHP

<?php
namespace Amp\Test;
use Amp\Deferred;
use Amp\Delayed;
use Amp\Failure;
use Amp\Loop;
use Amp\PHPUnit\TestException;
use Amp\Promise;
use Amp\Success;
use function React\Promise\resolve;
class WaitTest extends BaseTest
{
public function testWaitOnSuccessfulPromise()
{
$value = 1;
$promise = new Success($value);
$result = Promise\wait($promise);
$this->assertSame($value, $result);
}
public function testWaitOnFailedPromise()
{
$exception = new \Exception();
$promise = new Failure($exception);
try {
$result = Promise\wait($promise);
} catch (\Exception $e) {
$this->assertSame($exception, $e);
return;
}
$this->fail('Rejection exception should be thrown from wait().');
}
/**
* @depends testWaitOnSuccessfulPromise
*/
public function testWaitOnPendingPromise()
{
Loop::run(function () {
$value = 1;
$promise = new Delayed(100, $value);
$result = Promise\wait($promise);
$this->assertSame($value, $result);
});
}
/**
* @expectedException \Error
* @expectedExceptionMessage Loop stopped without resolving the promise
*/
public function testPromiseWithNoResolutionPathThrowsException()
{
Promise\wait((new Deferred)->promise());
}
/**
* @expectedException \Error
* @expectedExceptionMessage Loop exceptionally stopped without resolving the promise
*/
public function testPromiseWithErrorBeforeResolutionThrowsException()
{
Loop::defer(function () {
throw new TestException;
});
Promise\wait((new Deferred)->promise());
}
/**
* @depends testWaitOnSuccessfulPromise
*/
public function testReactPromise()
{
$value = 1;
$promise = resolve($value);
$result = Promise\wait($promise);
$this->assertSame($value, $result);
}
public function testNonPromise()
{
$this->expectException(\TypeError::class);
Promise\wait(42);
}
}