Add fiber interoperability support

WyriHaximus · WyriHaximus · commit 145ed6a63fb1 · 2021-11-22T15:18:47.000+01:00
While there is no technical need to add this for this, we also don't want to block other projects creating adapters. However, this interoperability support is undocumented and as such unsupported. Use at your own risk.
diff --git a/src/FiberFactory.php b/src/FiberFactory.php
@@ -0,0 +1,33 @@
+<?php
+
+namespace React\Async;
+
+/**
+ * This factory its only purpose is interoperability. Where with
+ * event loops one could simply wrap another event loop. But with fibers
+ * that has become impossible and as such we provide this factory and the
+ * FiberInterface.
+ *
+ * Usage is not documented and as such not supported and might chang without
+ * notice. Use at your own risk.
+ *
+ * @internal
+ */
+final class FiberFactory
+{
+    private static ?\Closure $factory = null;
+
+    public static function create(): FiberInterface
+    {
+        return (self::factory())();
+    }
+
+    public static function factory(\Closure $factory = null): \Closure
+    {
+        if ($factory !== null) {
+            self::$factory = $factory;
+        }
+
+        return self::$factory ?? static fn (): FiberInterface => new SimpleFiber();
+    }
+}
diff --git a/src/FiberInterface.php b/src/FiberInterface.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace React\Async;
+
+/**
+ * This interface its only purpose is interoperability. Where with
+ * event loops one could simply wrap another event loop. But with fibers
+ * that has become impossible and as such we provide this interface and the
+ * FiberFactory.
+ *
+ * Usage is not documented and as such not supported and might chang without
+ * notice. Use at your own risk.
+ *
+ * @internal
+ */
+interface FiberInterface
+{
+    public function resume(mixed $value): void;
+
+    public function throw(mixed $throwable): void;
+
+    public function suspend(): mixed;
+}
diff --git a/src/SimpleFiber.php b/src/SimpleFiber.php
@@ -7,7 +7,7 @@
 /**
  * @internal
  */
-final class SimpleFiber
+final class SimpleFiber implements FiberInterface
 {
     private static ?\Fiber $scheduler = null;
     private ?\Fiber $fiber = null;
diff --git a/src/functions.php b/src/functions.php
@@ -78,7 +78,7 @@ function async(callable $function, mixed ...$args): PromiseInterface
  */
 function await(PromiseInterface $promise): mixed
 {
-    $fiber = new SimpleFiber();
+    $fiber = FiberFactory::create();
 
     $promise->then(
         function (mixed $value) use (&$resolved, $fiber): void {

Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@`
`7`	`7`	`/**`
`8`	`8`	`* @internal`
`9`	`9`	`*/`
`10`		`-final class SimpleFiber`
	`10`	`+final class SimpleFiber implements FiberInterface`
`11`	`11`	`{`
`12`	`12`	`private static ?\Fiber $scheduler = null;`
`13`	`13`	`private ?\Fiber $fiber = null;`
Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ function async(callable $function, mixed ...$args): PromiseInterface`
`78`	`78`	`*/`
`79`	`79`	`function await(PromiseInterface $promise): mixed`
`80`	`80`	`{`
`81`		`- $fiber = new SimpleFiber();`
	`81`	`+ $fiber = FiberFactory::create();`
`82`	`82`
`83`	`83`	`$promise->then(`
`84`	`84`	`function (mixed $value) use (&$resolved, $fiber): void {`