function EachPromise::advanceIterator

2 calls to EachPromise::advanceIterator()

EachPromise::refillPending in vendor/guzzlehttp/promises/src/EachPromise.php

EachPromise::step in vendor/guzzlehttp/promises/src/EachPromise.php

File

vendor/guzzlehttp/promises/src/EachPromise.php, line 196

Class

EachPromise

Represents a promise that iterates over many promises and invokes side-effect functions in the process.

Namespace

GuzzleHttp\Promise

Code

private function advanceIterator() : bool {
    // Place a lock on the iterator so that we ensure to not recurse,
    // preventing fatal generator errors.
    if ($this->mutex) {
        return false;
    }
    $this->mutex = true;
    try {
        $this->iterable
            ->next();
        $this->mutex = false;
        return true;
    } catch (\Throwable $e) {
        $this->aggregate
            ->reject($e);
        $this->mutex = false;
        return false;
    }
}