Skip to content

Commit dd6a739

Browse files
committed
Remove internal Queue leftovers
1 parent ee59eae commit dd6a739

File tree

5 files changed

+10
-130
lines changed

5 files changed

+10
-130
lines changed

src/Internal/FulfilledPromise.php

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44

55
use React\Promise\Promise;
66
use React\Promise\PromiseInterface;
7-
use function React\Promise\enqueue;
87
use function React\Promise\resolve;
98

109
/**
@@ -30,13 +29,11 @@ public function then(callable $onFulfilled = null, callable $onRejected = null):
3029
}
3130

3231
return new Promise(function (callable $resolve, callable $reject) use ($onFulfilled): void {
33-
enqueue(function () use ($resolve, $reject, $onFulfilled): void {
34-
try {
35-
$resolve($onFulfilled($this->value));
36-
} catch (\Throwable $exception) {
37-
$reject($exception);
38-
}
39-
});
32+
try {
33+
$resolve($onFulfilled($this->value));
34+
} catch (\Throwable $exception) {
35+
$reject($exception);
36+
}
4037
});
4138
}
4239

src/Internal/Queue.php

Lines changed: 0 additions & 30 deletions
This file was deleted.

src/Internal/RejectedPromise.php

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
use React\Promise\Promise;
66
use React\Promise\PromiseInterface;
77
use function React\Promise\_checkTypehint;
8-
use function React\Promise\enqueue;
98
use function React\Promise\resolve;
109

1110
/**
@@ -27,13 +26,11 @@ public function then(callable $onFulfilled = null, callable $onRejected = null):
2726
}
2827

2928
return new Promise(function (callable $resolve, callable $reject) use ($onRejected): void {
30-
enqueue(function () use ($resolve, $reject, $onRejected): void {
31-
try {
32-
$resolve($onRejected($this->reason));
33-
} catch (\Throwable $exception) {
34-
$reject($exception);
35-
}
36-
});
29+
try {
30+
$resolve($onRejected($this->reason));
31+
} catch (\Throwable $exception) {
32+
$reject($exception);
33+
}
3734
});
3835
}
3936

src/functions.php

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -205,20 +205,6 @@ function (\Throwable $reason) use ($i, &$reasons, &$toReject, $reject, &$continu
205205
}, $cancellationQueue);
206206
}
207207

208-
/**
209-
* @internal
210-
*/
211-
function enqueue(callable $task): void
212-
{
213-
static $queue;
214-
215-
if (!$queue) {
216-
$queue = new Internal\Queue();
217-
}
218-
219-
$queue->enqueue($task);
220-
}
221-
222208
/**
223209
* @internal
224210
*/

tests/Internal/QueueTest.php

Lines changed: 0 additions & 70 deletions
This file was deleted.

0 commit comments

Comments
 (0)