ACIL FM

Pilih semua

Nama	Ukuran	Aksi
CompositeStream.php	1.85 MB	View DL Edit
DuplexResourceStream.php	7.38 MB	View DL Edit
DuplexStreamInterface.php	1.7 MB	View DL Edit
ReadableResourceStream.php	5.96 MB	View DL Edit
ReadableStreamInterface.php	13.93 MB	View DL Edit
ThroughStream.php	5.15 MB	View DL Edit
Util.php	2.23 MB	View DL Edit
WritableResourceStream.php	5.5 MB	View DL Edit
WritableStreamInterface.php	14.43 MB	View DL Edit

Edit file: /opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/stream/src/ThroughStream.php

<?php

namespace RectorPrefix202411\React\Stream;

use RectorPrefix202411\Evenement\EventEmitter;
use InvalidArgumentException;
/**
 * The `ThroughStream` implements the
 * [`DuplexStreamInterface`](#duplexstreaminterface) and will simply pass any data
 * you write to it through to its readable end.
 *
 * ```php
 * $through = new ThroughStream();
 * $through->on('data', $this->expectCallableOnceWith('hello'));
 *
 * $through->write('hello');
 * ```
 *
 * Similarly, the [`end()` method](#end) will end the stream and emit an
 * [`end` event](#end-event) and then [`close()`](#close-1) the stream.
 * The [`close()` method](#close-1) will close the stream and emit a
 * [`close` event](#close-event).
 * Accordingly, this is can also be used in a [`pipe()`](#pipe) context like this:
 *
 * ```php
 * $through = new ThroughStream();
 * $source->pipe($through)->pipe($dest);
 * ```
 *
 * Optionally, its constructor accepts any callable function which will then be
 * used to *filter* any data written to it. This function receives a single data
 * argument as passed to the writable side and must return the data as it will be
 * passed to its readable end:
 *
 * ```php
 * $through = new ThroughStream('strtoupper');
 * $source->pipe($through)->pipe($dest);
 * ```
 *
 * Note that this class makes no assumptions about any data types. This can be
 * used to convert data, for example for transforming any structured data into
 * a newline-delimited JSON (NDJSON) stream like this:
 *
 * ```php
 * $through = new ThroughStream(function ($data) {
 *     return json_encode($data) . PHP_EOL;
 * });
 * $through->on('data', $this->expectCallableOnceWith("[2, true]\n"));
 *
 * $through->write(array(2, true));
 * ```
 *
 * The callback function is allowed to throw an `Exception`. In this case,
 * the stream will emit an `error` event and then [`close()`](#close-1) the stream.
 *
 * ```php
 * $through = new ThroughStream(function ($data) {
 *     if (!is_string($data)) {
 *         throw new \UnexpectedValueException('Only strings allowed');
 *     }
 *     return $data;
 * });
 * $through->on('error', $this->expectCallableOnce()));
 * $through->on('close', $this->expectCallableOnce()));
 * $through->on('data', $this->expectCallableNever()));
 *
 * $through->write(2);
 * ```
 *
 * @see WritableStreamInterface::write()
 * @see WritableStreamInterface::end()
 * @see DuplexStreamInterface::close()
 * @see WritableStreamInterface::pipe()
 */
final class ThroughStream extends EventEmitter implements DuplexStreamInterface
{
    private $readable = \true;
    private $writable = \true;
    private $closed = \false;
    private $paused = \false;
    private $drain = \false;
    private $callback;
    public function __construct($callback = null)
    {
        if ($callback !== null && !\is_callable($callback)) {
            throw new InvalidArgumentException('Invalid transformation callback given');
        }
        $this->callback = $callback;
    }
    public function pause()
    {
        // only allow pause if still readable, false otherwise
        $this->paused = $this->readable;
    }
    public function resume()
    {
        $this->paused = \false;
        // emit drain event if previous write was paused (throttled)
        if ($this->drain) {
            $this->drain = \false;
            $this->emit('drain');
        }
    }
    public function pipe(WritableStreamInterface $dest, array $options = array())
    {
        return Util::pipe($this, $dest, $options);
    }
    public function isReadable()
    {
        return $this->readable;
    }
    public function isWritable()
    {
        return $this->writable;
    }
    public function write($data)
    {
        if (!$this->writable) {
            return \false;
        }
        if ($this->callback !== null) {
            try {
                $data = \call_user_func($this->callback, $data);
            } catch (\Exception $e) {
                $this->emit('error', array($e));
                $this->close();
                return \false;
            }
        }
        $this->emit('data', array($data));
        // emit drain event on next resume if currently paused (throttled)
        if ($this->paused) {
            $this->drain = \true;
        }
        // continue writing if still writable and not paused (throttled), false otherwise
        return $this->writable && !$this->paused;
    }
    public function end($data = null)
    {
        if (!$this->writable) {
            return;
        }
        if (null !== $data) {
            $this->write($data);
            // return if write() already caused the stream to close
            if (!$this->writable) {
                return;
            }
        }
        $this->readable = \false;
        $this->writable = \false;
        $this->paused = \false;
        $this->drain = \false;
        $this->emit('end');
        $this->close();
    }
    public function close()
    {
        if ($this->closed) {
            return;
        }
        $this->readable = \false;
        $this->writable = \false;
        $this->paused = \false;
        $this->drain = \false;
        $this->closed = \true;
        $this->callback = null;
        $this->emit('close');
        $this->removeAllListeners();
    }
}

Batal

Isi Zip:

Create