refactor: use Coroutine\go to Coroutine::create

cydrickn · May 10, 2023 · 977b6ed · 977b6ed
1 parent 0b53f21
commit 977b6ed
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/src/EventDispatcher.php b/src/EventDispatcher.php
@@ -10,7 +10,7 @@ class EventDispatcher
 
     public function emit(string $eventName, ...$args): void
     {
-        Coroutine\go(function () use ($eventName, $args) {
+        Coroutine::create(function () use ($eventName, $args) {
             $events = $this->events[$eventName] ?? [];
             if (empty($events)) {
                 return;

diff --git a/src/Peer.php b/src/Peer.php
@@ -2,7 +2,7 @@
 
 namespace Octamp\Client;
 
-use Co\Http\Client as SwooleClient;
+use Swoole\Coroutine\Http\Client as SwooleClient;
 use Octamp\Client\Roles\AbstractRole;
 use Octamp\Client\Roles\Callee;
 use Octamp\Client\Roles\Caller;
@@ -78,17 +78,17 @@ public function open(): void
         ]);
 
         $upgraded = $this->client->upgrade($this->path);
-        Coroutine\go(function () use ($upgraded)  {
+        Coroutine::create(function () use ($upgraded)  {
             if ($upgraded) {
                 $this->startSession();
             }
         });
 
-        Coroutine\go(function () {
+        Coroutine::create(function () {
             while ($this->client->connected) {
                 Coroutine::usleep(1);
                 $data = $this->client->recv();
-                Coroutine\go(function ($data) {
+                Coroutine::create(function ($data) {
                     $this->onMessage($data);
                 }, $data);
             }
@@ -134,9 +134,9 @@ public function onMessage(Frame|bool $data): void
         } elseif ($message instanceof WelcomeMessage) {
             $this->processWelcome($message);
         } elseif ($message instanceof AbortMessage) {
-
+            // TODO do abort message
         } elseif ($message instanceof GoodbyeMessage) {
-
+            // TODO do goodby message
         } else {
             $this->processOther($this->session, $message);
         }