Method pump

src/FileRise/Storage/CurlReadStream.php:175–204

(int $desiredBytes)

    }

    private function pump(int $desiredBytes): void
    {
        while (!$this->done && !$this->closed && $this->availableBytes() < $desiredBytes) {
            $running = 0;
            do {
                $status = curl_multi_exec($this->multiHandle, $running);
            } while ($status === CURLM_CALL_MULTI_PERFORM);

            if ($status !== CURLM_OK) {
                $this->fail('WebDAV read failed to progress.');
                return;
            }

            $this->collectCompletedTransfers();
            if ($this->done || $this->availableBytes() >= $desiredBytes) {
                break;
            }

            if ($running <= 0) {
                $this->done = true;
                $this->closeCurlHandles();
                break;
            }

            $selected = curl_multi_select($this->multiHandle, 1.0);
            if ($selected === -1) {
                usleep(10000);
            }
        }
    }

    private function collectCompletedTransfers(): void
    {