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

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

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

diff --git a/assets/php/vendor/react/stream/src/WritableResourceStream.php b/assets/php/vendor/react/stream/src/WritableResourceStream.php
new file mode 100644
index 0000000..7e04205
--- /dev/null
+++ b/assets/php/vendor/react/stream/src/WritableResourceStream.php
@@ -0,0 +1,171 @@
+<?php
+
+namespace React\Stream;
+
+use Evenement\EventEmitter;
+use React\EventLoop\LoopInterface;
+
+final class WritableResourceStream extends EventEmitter implements WritableStreamInterface
+{
+    private $stream;
+    private $loop;
+    private $softLimit;
+    private $writeChunkSize;
+
+    private $listening = false;
+    private $writable = true;
+    private $closed = false;
+    private $data = '';
+
+    public function __construct($stream, LoopInterface $loop, $writeBufferSoftLimit = null, $writeChunkSize = null)
+    {
+        if (!is_resource($stream) || get_resource_type($stream) !== "stream") {
+            throw new \InvalidArgumentException('First parameter must be a valid stream resource');
+        }
+
+        // ensure resource is opened for writing (fopen mode must contain either of "waxc+")
+        $meta = stream_get_meta_data($stream);
+        if (isset($meta['mode']) && $meta['mode'] !== '' && strtr($meta['mode'], 'waxc+', '.....') === $meta['mode']) {
+            throw new \InvalidArgumentException('Given stream resource is not opened in write mode');
+        }
+
+        // this class relies on non-blocking I/O in order to not interrupt the event loop
+        // e.g. pipes on Windows do not support this: https://bugs.php.net/bug.php?id=47918
+        if (stream_set_blocking($stream, 0) !== true) {
+            throw new \RuntimeException('Unable to set stream resource to non-blocking mode');
+        }
+
+        $this->stream = $stream;
+        $this->loop = $loop;
+        $this->softLimit = ($writeBufferSoftLimit === null) ? 65536 : (int)$writeBufferSoftLimit;
+        $this->writeChunkSize = ($writeChunkSize === null) ? -1 : (int)$writeChunkSize;
+    }
+
+    public function isWritable()
+    {
+        return $this->writable;
+    }
+
+    public function write($data)
+    {
+        if (!$this->writable) {
+            return false;
+        }
+
+        $this->data .= $data;
+
+        if (!$this->listening && $this->data !== '') {
+            $this->listening = true;
+
+            $this->loop->addWriteStream($this->stream, array($this, 'handleWrite'));
+        }
+
+        return !isset($this->data[$this->softLimit - 1]);
+    }
+
+    public function end($data = null)
+    {
+        if (null !== $data) {
+            $this->write($data);
+        }
+
+        $this->writable = false;
+
+        // close immediately if buffer is already empty
+        // otherwise wait for buffer to flush first
+        if ($this->data === '') {
+            $this->close();
+        }
+    }
+
+    public function close()
+    {
+        if ($this->closed) {
+            return;
+        }
+
+        if ($this->listening) {
+            $this->listening = false;
+            $this->loop->removeWriteStream($this->stream);
+        }
+
+        $this->closed = true;
+        $this->writable = false;
+        $this->data = '';
+
+        $this->emit('close');
+        $this->removeAllListeners();
+
+        if (is_resource($this->stream)) {
+            fclose($this->stream);
+        }
+    }
+
+    /** @internal */
+    public function handleWrite()
+    {
+        $error = null;
+        set_error_handler(function ($errno, $errstr, $errfile, $errline) use (&$error) {
+            $error = array(
+                'message' => $errstr,
+                'number' => $errno,
+                'file' => $errfile,
+                'line' => $errline
+            );
+        });
+
+        if ($this->writeChunkSize === -1) {
+            $sent = fwrite($this->stream, $this->data);
+        } else {
+            $sent = fwrite($this->stream, $this->data, $this->writeChunkSize);
+        }
+
+        restore_error_handler();
+
+        // Only report errors if *nothing* could be sent.
+        // Any hard (permanent) error will fail to send any data at all.
+        // Sending excessive amounts of data will only flush *some* data and then
+        // report a temporary error (EAGAIN) which we do not raise here in order
+        // to keep the stream open for further tries to write.
+        // Should this turn out to be a permanent error later, it will eventually
+        // send *nothing* and we can detect this.
+        if ($sent === 0 || $sent === false) {
+            if ($error !== null) {
+                $error = new \ErrorException(
+                    $error['message'],
+                    0,
+                    $error['number'],
+                    $error['file'],
+                    $error['line']
+                );
+            }
+
+            $this->emit('error', array(new \RuntimeException('Unable to write to stream: ' . ($error !== null ? $error->getMessage() : 'Unknown error'), 0, $error)));
+            $this->close();
+
+            return;
+        }
+
+        $exceeded = isset($this->data[$this->softLimit - 1]);
+        $this->data = (string) substr($this->data, $sent);
+
+        // buffer has been above limit and is now below limit
+        if ($exceeded && !isset($this->data[$this->softLimit - 1])) {
+            $this->emit('drain');
+        }
+
+        // buffer is now completely empty => stop trying to write
+        if ($this->data === '') {
+            // stop waiting for resource to be writable
+            if ($this->listening) {
+                $this->loop->removeWriteStream($this->stream);
+                $this->listening = false;
+            }
+
+            // buffer is end()ing and now completely empty => close buffer
+            if (!$this->writable) {
+                $this->close();
+            }
+        }
+    }
+}
-- 
cgit v1.2.3