We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d177dd9 commit dc42aa0Copy full SHA for dc42aa0
1 file changed
src/CancellationQueue.php
@@ -5,6 +5,10 @@
5
class CancellationQueue
6
{
7
private $started = false;
8
+
9
+ /**
10
+ * @var CancellablePromiseInterface[]
11
+ */
12
private $queue = [];
13
14
public function __invoke()
@@ -33,7 +37,6 @@ public function enqueue($promise)
33
37
private function drain()
34
38
35
39
for ($i = key($this->queue); isset($this->queue[$i]); $i++) {
36
- /** @var CancellablePromiseInterface $promise */
40
$promise = $this->queue[$i];
41
42
$exception = null;
0 commit comments