X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fseekat;a=blobdiff_plain;f=lib%2FAPI%2FFuture%2Ffunctions.php;fp=lib%2FAPI%2FFuture%2Ffunctions.php;h=34d38c5adbe78d55c59b9c3a223f8cea11017aa0;hp=0000000000000000000000000000000000000000;hb=f4aa6beaf2e1f0dc9c877782cbbad5a989194517;hpb=626d8937c75f6d8fca463fa2b374f645068b2d6d

diff --git a/lib/API/Future/functions.php b/lib/API/Future/functions.php
new file mode 100644
index 0000000..34d38c5
--- /dev/null
+++ b/lib/API/Future/functions.php
@@ -0,0 +1,168 @@
+<?php
+
+namespace seekat\API\Future;
+
+use Amp\Deferred as AmpDeferred;
+use AsyncInterop\Promise;
+use Icicle\Awaitable\Deferred as IcicleDeferred;
+use React\Promise\Deferred as ReactDeferred;
+use seekat\API\Future;
+
+/**
+ * @param Future $future
+ * @param mixed $value
+ * @return Promise
+ */
+function resolve(Future $future, $value) {
+	$promisor = $future->createContext();
+	$future->onSuccess($promisor, $value);
+	return $future->getPromise($promisor);
+}
+
+/**
+ * @param Future $future
+ * @param mixed $reason
+ * @return Promise
+ */
+function reject(Future $future, $reason) {
+	$promisor = $future->createContext();
+	$future->onFailure($promisor, $reason);
+	return $future->getPromise($promisor);
+}
+
+/**
+ * @param Future $future
+ * @param mixed $context Promisor
+ * @return \Closure
+ */
+function resolver(Future $future, $context) {
+	return function($value) use($future, $context) {
+		return $future->onSuccess($context, $value);
+	};
+}
+
+/**
+ * @param Future $future
+ * @param mixed $context Promisor
+ * @return \Closure
+ */
+function rejecter(Future $future, $context) {
+	return function($reason) use($future, $context) {
+		return $future->onFailure($context, $reason);
+	};
+}
+
+/**
+ * @param Future $future
+ * @param mixed $context Promisor
+ * @return \Closure
+ */
+function updater(Future $future, $context) {
+	return function($update) use($future, $context) {
+		return $future->onUpdate($context, $update);
+	};
+}
+
+/**
+ * @return Future
+ */
+function react() {
+	return new class implements Future {
+		/**
+		 * @param callable|null $onCancel
+		 * @return ReactDeferred
+		 */
+		function createContext(callable $onCancel = null) {
+			return new ReactDeferred($onCancel);
+		}
+
+		function getPromise($context) : Promise {
+			/* @var $context ReactDeferred */
+			return $context->promise();
+		}
+
+		function onSuccess($context, $value) {
+			/* @var $context ReactDeferred */
+			$context->resolve($value);
+		}
+
+		function onFailure($context, $reason) {
+			/* @var $context ReactDeferred */
+			$context->reject($reason);
+		}
+
+		function onUpdate($context, $update) {
+			/* @var $context ReactDeferred */
+			$context->notify($update);
+		}
+	};
+}
+
+/**
+ * @return Future
+ */
+function amp() {
+	return new class implements Future {
+		/**
+		 * @return AmpDeferred
+		 */
+		function createContext(callable $onCancel = null) {
+			return new AmpDeferred();
+		}
+
+		function getPromise($context) : Promise {
+			/* @var $context AmpDeferred */
+			return $context->promise();
+		}
+
+		function onSuccess($context, $value) {
+			/* @var $context AmpDeferred */
+			$context->resolve($value);
+		}
+
+		function onFailure($context, $reason) {
+			/* @var $context AmpDeferred */
+			$context->fail($reason);
+		}
+
+		function onUpdate($context, $update) {
+			/* @var $context AmpDeferred */
+			/* noop */
+		}
+	};
+}
+
+/**
+ * @return Future
+ */
+function icicle() {
+	return new class implements Future {
+		/**
+		 * @param callable|null $onCancel
+		 * @return IcicleDeferred
+		 */
+		function createContext(callable $onCancel = null) {
+			return new IcicleDeferred($onCancel);
+		}
+
+		function getPromise($context): Promise {
+			/* @var $context IcicleDeferred */
+			return $context->getPromise();
+		}
+
+		function onSuccess($context, $value) {
+			/* @var $context IcicleDeferred */
+			$context->resolve($value);
+		}
+
+		function onFailure($context, $reason) {
+			/* @var $context IcicleDeferred */
+			$context->reject($reason);
+		}
+
+		function onUpdate($context, $update) {
+			/* @var $context IcicleDeferred */
+			/* noop */
+		}
+	};
+}