Admin

name	type	size	perms	modified	actions
[parent directory]
CompositeStream.php	file	1,896 B	0644	2024-11-08 13:59:10	edit
DuplexResourceStream.php	file	7,557 B	0644	2024-11-08 13:59:10	edit
DuplexStreamInterface.php	file	1,744 B	0644	2024-11-08 13:59:10	edit
ReadableResourceStream.php	file	6,108 B	0644	2024-11-08 13:59:10	edit
ReadableStreamInterface.php	file	14,269 B	0644	2024-11-08 13:59:10	edit
ThroughStream.php	file	5,272 B	0644	2024-11-08 13:59:10	edit
Util.php	file	2,285 B	0644	2024-11-08 13:59:10	edit
WritableResourceStream.php	file	5,628 B	0644	2024-11-08 13:59:10	edit
WritableStreamInterface.php	file	14,778 B	0644	2024-11-08 13:59:10	edit

editing: CompositeStream.php

<?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();
    }
}

cancel