fix: Make rejection handlers reusable;

remove `exit(255)` from RejectionPromise;

Author: roxblnfk

composer.json

@@ -64,7 +64,7 @@
         "sort-packages": true
     },
     "scripts": {
-        "stan": "stan",
+        "stan": "phpstan",
         "test": "phpunit --color=always --testdox",
         "test:cc": [
             "@putenv XDEBUG_MODE=coverage",

src/Internal/RejectedPromise.php

@@ -14,44 +14,35 @@
  */
 final class RejectedPromise implements PromiseInterface
 {
-    /** @var \Throwable */
-    private $reason;
+    private \Throwable $reason;
+    private bool $handled = false;
+    private static ?\Closure $rejectionHandler = null;
 
-    /** @var bool */
-    private $handled = false;
-
-    /**
-     * @param \Throwable $reason
-     */
     public function __construct(\Throwable $reason)
     {
         $this->reason = $reason;
     }
 
+    public static function setRejectionHandler(?callable $handler): void
+    {
+        self::$rejectionHandler = $handler === null ? null : $handler(...);
+    }
+
     /** @throws void */
     public function __destruct()
     {
-        if ($this->handled) {
-            return;
-        }
-
-        $handler = set_rejection_handler(null);
-        if ($handler === null) {
-            $message = 'Unhandled promise rejection with ' . $this->reason;
-
-            \error_log($message);
+        if ($this->handled || self::$rejectionHandler === null) {
             return;
         }
 
         try {
-            $handler($this->reason);
+            (self::$rejectionHandler)($this->reason);
         } catch (\Throwable $e) {
             \preg_match('/^([^:\s]++)(.*+)$/sm', (string) $e, $match);
             \assert(isset($match[1], $match[2]));
             $message = 'Fatal error: Uncaught ' . $match[1] . ' from unhandled promise rejection handler' . $match[2];
 
             \error_log($message);
-            exit(255);
         }
     }
 

src/functions.php

@@ -249,18 +249,21 @@ function (\Throwable $reason) use ($i, &$reasons, &$toReject, $reject, &$continu
  * [`finally()` method](#promiseinterfacefinally).
  * See also the [`reject()` function](#reject) for more details.
  *
- * @param callable(\Throwable):void|null $callback
- * @return callable(\Throwable):void|null
+ * @param callable(\Throwable):mixed|null $callback
+ * @return callable(\Throwable):mixed|null
  */
 function set_rejection_handler(?callable $callback): ?callable
 {
     static $current = null;
     $previous = $current;
     $current = $callback;
+    RejectedPromise::setRejectionHandler($current);
 
     return $previous;
 }
 
+set_rejection_handler(static fn(\Throwable $reason) => \error_log('Unhandled promise rejection with ' . $reason));
+
 /**
  * @internal
  */