function CancellationQueue::drain

2 calls to CancellationQueue::drain()

CancellationQueue::enqueue in vendor/react/promise/src/Internal/CancellationQueue.php

CancellationQueue::__invoke in vendor/react/promise/src/Internal/CancellationQueue.php

File

vendor/react/promise/src/Internal/CancellationQueue.php, line 42

Class

CancellationQueue

@internal

Namespace

React\Promise\Internal

Code

private function drain() : void {
    for ($i = \key($this->queue); isset($this->queue[$i]); $i++) {
        $cancellable = $this->queue[$i];
        assert(\method_exists($cancellable, 'cancel'));
        $exception = null;
        try {
            $cancellable->cancel();
        } catch (\Throwable $exception) {
        }
        unset($this->queue[$i]);
        if ($exception) {
            throw $exception;
        }
    }
    $this->queue = [];
}