add go loop

Author: amuluowin

src/functions.php

@@ -6,6 +6,8 @@
  * Time: 15:21
  */
 
+use rabbit\helper\ExceptionHelper;
+
 defined('BREAKS') or define('BREAKS', PHP_SAPI === 'cli' ? PHP_EOL : '</br>');
 
 if (!function_exists('getDI')) {
@@ -81,3 +83,22 @@ function hasDef(string $key): bool
         return \rabbit\core\ObjectFactory::hasDef($key);
     }
 }
+
+if (!function_exists('goloop')) {
+    /**
+     * @param string $key
+     * @return bool
+     */
+    function goloop(\Closure $function): int
+    {
+        return go(function () use ($function) {
+            while (true) {
+                try {
+                    $function();
+                } catch (\Throwable $throwable) {
+                    print_r(ExceptionHelper::convertExceptionToArray($throwable));
+                }
+            }
+        });
+    }
+}

src/helper/CoroHelper.php

@@ -85,7 +85,7 @@ public static function addDefer(callable $function): void
      * @param \Closure $function
      * @param \Closure|null $defer
      */
-    public static function run(\Closure $function, ?\Closure $defer = null)
+    public static function run(\Closure $function, ?\Closure $defer = null): void
     {
         \Co\run(function () use ($function, $defer) {
             try {
@@ -98,4 +98,25 @@ public static function run(\Closure $function, ?\Closure $defer = null)
             }
         });
     }
+
+    /**
+     * @param \Closure $function
+     * @param \Closure|null $defer
+     * @return int
+     */
+    public static function loop(\Closure $function, ?\Closure $defer = null): int
+    {
+        return go(function () use ($function, $defer) {
+            while (true) {
+                try {
+                    if (is_callable($defer)) {
+                        defer($defer);
+                    }
+                    $function();
+                } catch (\Throwable $throwable) {
+                    print_r(ExceptionHelper::convertExceptionToArray($throwable));
+                }
+            }
+        });
+    }
 }