?HAMA

Edit File Size: 1.85 KB

/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/stream/src/CompositeStream.php

Text Base64

<?php

namespace RectorPrefix202411\React\Stream;

use RectorPrefix202411\Evenement\EventEmitter;
final class CompositeStream extends EventEmitter implements DuplexStreamInterface
{
    private $readable;
    private $writable;
    private $closed = \false;
    public function __construct(ReadableStreamInterface $readable, WritableStreamInterface $writable)
    {
        $this->readable = $readable;
        $this->writable = $writable;
        if (!$readable->isReadable() || !$writable->isWritable()) {
            $this->close();
            return;
        }
        Util::forwardEvents($this->readable, $this, array('data', 'end', 'error'));
        Util::forwardEvents($this->writable, $this, array('drain', 'error', 'pipe'));
        $this->readable->on('close', array($this, 'close'));
        $this->writable->on('close', array($this, 'close'));
    }
    public function isReadable()
    {
        return $this->readable->isReadable();
    }
    public function pause()
    {
        $this->readable->pause();
    }
    public function resume()
    {
        if (!$this->writable->isWritable()) {
            return;
        }
        $this->readable->resume();
    }
    public function pipe(WritableStreamInterface $dest, array $options = array())
    {
        return Util::pipe($this, $dest, $options);
    }
    public function isWritable()
    {
        return $this->writable->isWritable();
    }
    public function write($data)
    {
        return $this->writable->write($data);
    }
    public function end($data = null)
    {
        $this->readable->pause();
        $this->writable->end($data);
    }
    public function close()
    {
        if ($this->closed) {
            return;
        }
        $this->closed = \true;
        $this->readable->close();
        $this->writable->close();
        $this->emit('close');
        $this->removeAllListeners();
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
CompositeStream.php	1.85 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
DuplexResourceStream.php	7.38 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
DuplexStreamInterface.php	1.70 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
ReadableResourceStream.php	5.96 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
ReadableStreamInterface.php	13.93 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
ThroughStream.php	5.15 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
Util.php	2.23 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
WritableResourceStream.php	5.50 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive
WritableStreamInterface.php	14.43 KB	lrw-r--r--	2024-11-08 13:59:10	Edit Download recursive recursive

Directory Contents