🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-06-15 06:50:36 | PHP 8.1.34
📂
/ (Root)
/
opt
/
cpanel
/
ea-wappspector
/
vendor
/
rector
/
rector
/
vendor
/
react
/
stream
/
src
📍 /opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/stream/src
🔄 Refresh
✏️
Editing: CompositeStream.php
Read Only
<?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(); } }
💾 Save Changes
❌ Cancel