ONE PIECE HACKING

Ngiler SH3LL 360
: / home / tbf / cursbackend / vendor / react / stream / src /

Information Server
MySQL : OFF Perl : OFF CURL : ON WGET : OFF PKEXEC : OFF

Directive	Local Value
IP Address	89.40.16.97
System	Linux server.atelieruldeit.ro 3.10.0-1160.el7.x86_64 #1 SMP Mon Oct 19 16:18:59 UTC 2020 x86_64
User	tbf
PHP Version	7.3.33
Software	Apache
Doc root	Writable

Edit File : CompositeStream.php \| Size : 1.83 KB
<?php namespace React\Stream; use 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(); } } Back

Edit File : CompositeStream.php | Size : 1.83 KB

<?php

namespace React\Stream;

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

Back