1 files changed, 70 insertions, 0 deletions
diff --git a/assets/php/vendor/react/promise-timer/src/functions.php b/assets/php/vendor/react/promise-timer/src/functions.php
new file mode 100644
index 0000000..6ad9867
--- /dev/null
+++ b/assets/php/vendor/react/promise-timer/src/functions.php
@@ -0,0 +1,70 @@
+<?php
+
+namespace React\Promise\Timer;
+
+use React\Promise\CancellablePromiseInterface;
+use React\EventLoop\LoopInterface;
+use React\Promise\PromiseInterface;
+use React\Promise\Promise;
+
+function timeout(PromiseInterface $promise, $time, LoopInterface $loop)
+{
+    // cancelling this promise will only try to cancel the input promise,
+    // thus leaving responsibility to the input promise.
+    $canceller = null;
+    if ($promise instanceof CancellablePromiseInterface) {
+        $canceller = array($promise, 'cancel');
+    }
+
+    return new Promise(function ($resolve, $reject) use ($loop, $time, $promise) {
+        $timer = null;
+        $promise->then(function ($v) use (&$timer, $loop, $resolve) {
+            if ($timer) {
+                $loop->cancelTimer($timer);
+            }
+            $timer = false;
+            $resolve($v);
+        }, function ($v) use (&$timer, $loop, $reject) {
+            if ($timer) {
+                $loop->cancelTimer($timer);
+            }
+            $timer = false;
+            $reject($v);
+        });
+
+        // promise already resolved => no need to start timer
+        if ($timer === false) {
+            return;
+        }
+
+        // start timeout timer which will cancel the input promise
+        $timer = $loop->addTimer($time, function () use ($time, $promise, $reject) {
+            $reject(new TimeoutException($time, 'Timed out after ' . $time . ' seconds'));
+
+            if ($promise instanceof CancellablePromiseInterface) {
+                $promise->cancel();
+            }
+        });
+    }, $canceller);
+}
+
+function resolve($time, LoopInterface $loop)
+{
+    return new Promise(function ($resolve) use ($loop, $time, &$timer) {
+        // resolve the promise when the timer fires in $time seconds
+        $timer = $loop->addTimer($time, function () use ($time, $resolve) {
+            $resolve($time);
+        });
+    }, function ($resolveUnused, $reject) use (&$timer, $loop) {
+        // cancelling this promise will cancel the timer and reject
+        $loop->cancelTimer($timer);
+        $reject(new \RuntimeException('Timer cancelled'));
+    });
+}
+
+function reject($time, LoopInterface $loop)
+{
+    return resolve($time, $loop)->then(function ($time) {
+        throw new TimeoutException($time, 'Timer expired after ' . $time . ' seconds');
+    });
+}