aboutsummaryrefslogtreecommitdiffhomepage
path: root/assets/php/vendor/react/promise-timer/src/functions.php
diff options
context:
space:
mode:
Diffstat (limited to 'assets/php/vendor/react/promise-timer/src/functions.php')
-rwxr-xr-xassets/php/vendor/react/promise-timer/src/functions.php70
1 files changed, 0 insertions, 70 deletions
diff --git a/assets/php/vendor/react/promise-timer/src/functions.php b/assets/php/vendor/react/promise-timer/src/functions.php
deleted file mode 100755
index 6ad9867..0000000
--- a/assets/php/vendor/react/promise-timer/src/functions.php
+++ /dev/null
@@ -1,70 +0,0 @@
-<?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');
- });
-}