golden hour

/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/stream/src

File/Folder	Size	Actions
CompositeStream.php	1.85 KB
DuplexResourceStream.php	7.38 KB
DuplexStreamInterface.php	1.7 KB
ReadableResourceStream.php	5.96 KB
ReadableStreamInterface.php	13.93 KB
ThroughStream.php	5.15 KB
Util.php	2.23 KB
WritableResourceStream.php	5.5 KB
WritableStreamInterface.php	14.43 KB

Edit: Util.php

<?php

namespace RectorPrefix202411\React\Stream;

final class Util
{
    /**
     * Pipes all the data from the given $source into the $dest
     *
     * @param ReadableStreamInterface $source
     * @param WritableStreamInterface $dest
     * @param array $options
     * @return WritableStreamInterface $dest stream as-is
     * @see ReadableStreamInterface::pipe() for more details
     */
    public static function pipe(ReadableStreamInterface $source, WritableStreamInterface $dest, array $options = array())
    {
        // source not readable => NO-OP
        if (!$source->isReadable()) {
            return $dest;
        }
        // destination not writable => just pause() source
        if (!$dest->isWritable()) {
            $source->pause();
            return $dest;
        }
        $dest->emit('pipe', array($source));
        // forward all source data events as $dest->write()
        $source->on('data', $dataer = function ($data) use($source, $dest) {
            $feedMore = $dest->write($data);
            if (\false === $feedMore) {
                $source->pause();
            }
        });
        $dest->on('close', function () use($source, $dataer) {
            $source->removeListener('data', $dataer);
            $source->pause();
        });
        // forward destination drain as $source->resume()
        $dest->on('drain', $drainer = function () use($source) {
            $source->resume();
        });
        $source->on('close', function () use($dest, $drainer) {
            $dest->removeListener('drain', $drainer);
        });
        // forward end event from source as $dest->end()
        $end = isset($options['end']) ? $options['end'] : \true;
        if ($end) {
            $source->on('end', $ender = function () use($dest) {
                $dest->end();
            });
            $dest->on('close', function () use($source, $ender) {
                $source->removeListener('end', $ender);
            });
        }
        return $dest;
    }
    public static function forwardEvents($source, $target, array $events)
    {
        foreach ($events as $event) {
            $source->on($event, function () use($event, $target) {
                $target->emit($event, \func_get_args());
            });
        }
    }
}