dep: package update
This commit is contained in:
1 parent
872755e57f
commit
6c3b9aafc1
783 files changed
+4581
-20980
No files matched your search
+4
-3
@@ -79,9 +79,7 @@ class EachPromise implements PromisorInterface
|
||||
$this->createPromise();
|
||||
/** @psalm-assert Promise $this->aggregate */
|
||||
$this->iterable->rewind();
|
||||
if (!$this->checkIfFinished()) {
|
||||
$this->refillPending();
|
||||
}
|
||||
$this->refillPending();
|
||||
} catch (\Throwable $e) {
|
||||
/**
|
||||
* @psalm-suppress NullReference
|
||||
@@ -107,6 +105,9 @@ class EachPromise implements PromisorInterface
|
||||
{
|
||||
$this->mutex = false;
|
||||
$this->aggregate = new Promise(function () {
|
||||
if ($this->checkIfFinished()) {
|
||||
return;
|
||||
}
|
||||
reset($this->pending);
|
||||
// Consume a potentially fluctuating list of promises while
|
||||
// ensuring that indexes are maintained (precluding array_shift).
|
||||
|
||||
+3
-1
@@ -48,7 +48,9 @@ final class Utils
|
||||
$promise = new Promise([$queue, 'run']);
|
||||
$queue->add(function () use ($task, $promise) {
|
||||
try {
|
||||
$promise->resolve($task());
|
||||
if (Is::pending($promise)) {
|
||||
$promise->resolve($task());
|
||||
}
|
||||
} catch (\Throwable $e) {
|
||||
$promise->reject($e);
|
||||
} catch (\Exception $e) {
|
||||
|
||||
Reference in new issue
Block a user