101 lines
2.5 KiB
PHP
101 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace React\Promise;
|
|
|
|
class CancellationQueueTest extends TestCase
|
|
{
|
|
/** @test */
|
|
public function acceptsSimpleCancellableThenable()
|
|
{
|
|
$p = new SimpleTestCancellableThenable();
|
|
|
|
$cancellationQueue = new CancellationQueue();
|
|
$cancellationQueue->enqueue($p);
|
|
|
|
$cancellationQueue();
|
|
|
|
$this->assertTrue($p->cancelCalled);
|
|
}
|
|
|
|
/** @test */
|
|
public function ignoresSimpleCancellable()
|
|
{
|
|
$p = new SimpleTestCancellable();
|
|
|
|
$cancellationQueue = new CancellationQueue();
|
|
$cancellationQueue->enqueue($p);
|
|
|
|
$cancellationQueue();
|
|
|
|
$this->assertFalse($p->cancelCalled);
|
|
}
|
|
|
|
/** @test */
|
|
public function callsCancelOnPromisesEnqueuedBeforeStart()
|
|
{
|
|
$d1 = $this->getCancellableDeferred();
|
|
$d2 = $this->getCancellableDeferred();
|
|
|
|
$cancellationQueue = new CancellationQueue();
|
|
$cancellationQueue->enqueue($d1->promise());
|
|
$cancellationQueue->enqueue($d2->promise());
|
|
|
|
$cancellationQueue();
|
|
}
|
|
|
|
/** @test */
|
|
public function callsCancelOnPromisesEnqueuedAfterStart()
|
|
{
|
|
$d1 = $this->getCancellableDeferred();
|
|
$d2 = $this->getCancellableDeferred();
|
|
|
|
$cancellationQueue = new CancellationQueue();
|
|
|
|
$cancellationQueue();
|
|
|
|
$cancellationQueue->enqueue($d2->promise());
|
|
$cancellationQueue->enqueue($d1->promise());
|
|
}
|
|
|
|
/** @test */
|
|
public function doesNotCallCancelTwiceWhenStartedTwice()
|
|
{
|
|
$d = $this->getCancellableDeferred();
|
|
|
|
$cancellationQueue = new CancellationQueue();
|
|
$cancellationQueue->enqueue($d->promise());
|
|
|
|
$cancellationQueue();
|
|
$cancellationQueue();
|
|
}
|
|
|
|
/** @test */
|
|
public function rethrowsExceptionsThrownFromCancel()
|
|
{
|
|
$this->setExpectedException('\Exception', 'test');
|
|
|
|
$mock = $this
|
|
->getMockBuilder('React\Promise\CancellablePromiseInterface')
|
|
->getMock();
|
|
$mock
|
|
->expects($this->once())
|
|
->method('cancel')
|
|
->will($this->throwException(new \Exception('test')));
|
|
|
|
$cancellationQueue = new CancellationQueue();
|
|
$cancellationQueue->enqueue($mock);
|
|
|
|
$cancellationQueue();
|
|
}
|
|
|
|
private function getCancellableDeferred()
|
|
{
|
|
$mock = $this->createCallableMock();
|
|
$mock
|
|
->expects($this->once())
|
|
->method('__invoke');
|
|
|
|
return new Deferred($mock);
|
|
}
|
|
}
|