From fc9401f04a3aca5abb22f87ebc210de8afe11d32 Mon Sep 17 00:00:00 2001
From: marvin-borner@live.com
Date: Tue, 10 Apr 2018 21:50:16 +0200
Subject: Initial Commit

---
 .../vendor/react/stream/src/CompositeStream.php    | 82 ++++++++++++++++++++++
 1 file changed, 82 insertions(+)
 create mode 100644 assets/php/vendor/react/stream/src/CompositeStream.php

(limited to 'assets/php/vendor/react/stream/src/CompositeStream.php')

diff --git a/assets/php/vendor/react/stream/src/CompositeStream.php b/assets/php/vendor/react/stream/src/CompositeStream.php
new file mode 100644
index 0000000..153f2a3
--- /dev/null
+++ b/assets/php/vendor/react/stream/src/CompositeStream.php
@@ -0,0 +1,82 @@
+<?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()) {
+            return $this->close();
+        }
+
+        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();
+    }
+}
-- 
cgit v1.2.3