error handler for cli loop

utopia-php · Feb 18, 2022 · 0ab8f2f · 0ab8f2f
1 parent 5ff128a
commit 0ab8f2f
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/src/CLI/Console.php b/src/CLI/Console.php
@@ -190,16 +190,24 @@ static public function isInteractive(): bool
     /**
      * @param callable $callback
      * @param int $sleep in seconds
+     * @param callable $onError
      */
-    static public function loop(callable $callback, $sleep = 1 /* 1 second */): void
+    static public function loop(callable $callback, $sleep = 1 /* 1 second */, callable $onError = null): void
     {
         gc_enable();
 
         $time = 0;
 
         while (!connection_aborted() || PHP_SAPI == "cli") {
-
-            $callback();
+            try {
+                $callback();
+            } catch(\Exception $e) {
+                if($onError != null) {
+                    $onError($e);
+                } else {
+                    throw $e;
+                }
+            }
 
             sleep($sleep);