Update to version 0.8

composer.json

@@ -1,6 +1,6 @@
 {
   "name": "cloudtay/ripple",
-  "version": "v0.6.2",
+  "version": "v0.8.1",
   "license": "MIT",
   "autoload": {
     "psr-4": {

src/Kernel.php

@@ -37,12 +37,13 @@
 use Closure;
 use Co\Coroutine;
 use Co\System;
-use Ripple\Coroutine\Promise;
-use Ripple\Coroutine\Suspension;
 use Revolt\EventLoop;
 use Revolt\EventLoop\UnsupportedFeatureException;
+use Ripple\Coroutine\Promise;
+use Ripple\Coroutine\Suspension;
 use Symfony\Component\DependencyInjection\Container;
 use Throwable;
+use Fiber;
 
 use function call_user_func;
 use function Co\async;
@@ -244,7 +245,6 @@ public function cancelForked(string $index): void
      * @param Closure|null $result
      *
      * @return bool
-     * @throws Throwable
      */
     public function wait(Closure|null $result = null): bool
     {
@@ -255,6 +255,7 @@ public function wait(Closure|null $result = null): bool
         if (!$this->mainRunning) {
             try {
                 \Ripple\Coroutine\Coroutine::resume($this->mainSuspension, $result);
+                Fiber::suspend();
             } catch (Throwable) {
                 exit(1);
             }

src/Process/Process.php

@@ -200,12 +200,8 @@ public function task(Closure $closure): Task|false
                 // Whether it belongs to the ripple coroutine space
                 // forked and user actions need to be deferred because they clear the coroutine hash table
                 // If you don't do this, fiber escape will occur
-
-                EventLoop::defer(function () use ($closure, $args) {
-                    $this->forkedTick();
-                    call_user_func($closure, ...$args);
-                });
-
+                $this->forkedTick();
+                call_user_func($closure, ...$args);
                 throw new EscapeException('The process is abnormal.');
             }
 

tests/ProcessTest.php

@@ -42,9 +42,7 @@ public function test_coroutine(): void
         $async    = async(function () use ($code) {
             $task    = System::Process()->task(function () use ($code) {
                 \Co\sleep(1);
-                defer(function () use ($code) {
-                    exit($code);
-                });
+                exit($code);
             });
             $runtime = $task->run();
             return await($runtime->getPromise());