chore: update to revolt 0.2

Signed-off-by: azjezz <azjezz@protonmail.com>

composer.json

@@ -16,7 +16,7 @@
         "ext-mbstring": "*",
         "ext-sodium": "*",
         "ext-intl": "*",
-        "revolt/event-loop": "~0.1.1"
+        "revolt/event-loop": "~0.2.0"
     },
     "require-dev": {
         "squizlabs/php_codesniffer": "^3.6.1",

src/Psl/Async/Awaitable.php

@@ -249,7 +249,7 @@ public function always(Closure $always): Awaitable
      */
     public function await(): mixed
     {
-        $suspension = Scheduler::createSuspension();
+        $suspension = Scheduler::getSuspension();
 
         $this->state->subscribe(
             /**

src/Psl/Async/Internal/AwaitableIterator.php

@@ -136,7 +136,7 @@ public function consume(): ?array
                 return $this->complete->await();
             }
 
-            $this->queue->suspension = Psl\Async\Scheduler::createSuspension();
+            $this->queue->suspension = Psl\Async\Scheduler::getSuspension();
 
             /** @var null|array{0: Tk, 1: Awaitable<Tv>} */
             return $this->queue->suspension->suspend();

src/Psl/Async/Internal/State.php

@@ -50,8 +50,7 @@ final class State
     public function __destruct()
     {
         if ($this->exception && !$this->handled) {
-            $exception = Exception\UnhandledAwaitableException::forException($this->exception);
-            Scheduler::queue(static fn () => throw $exception);
+            throw Exception\UnhandledAwaitableException::forException($this->exception);
         }
     }
 

src/Psl/Async/KeyedSemaphore.php

@@ -67,7 +67,7 @@ public function waitFor(string|int $key, mixed $input): mixed
     {
         $this->ingoing[$key] = $this->ingoing[$key] ?? 0;
         if ($this->ingoing[$key] === $this->concurrencyLimit) {
-            $this->pending[$key][] = $suspension = Scheduler::createSuspension();
+            $this->pending[$key][] = $suspension = Scheduler::getSuspension();
 
             $suspension->suspend();
         }
@@ -259,7 +259,7 @@ public function waitForPending(string|int $key): void
             return;
         }
 
-        $suspension = Scheduler::createSuspension();
+        $suspension = Scheduler::getSuspension();
         $this->waits[$key][] = $suspension;
         $suspension->suspend();
     }

src/Psl/Async/KeyedSequence.php

@@ -61,7 +61,7 @@ public function __construct(
     public function waitFor(string|int $key, mixed $input): mixed
     {
         if (array_key_exists($key, $this->ingoing)) {
-            $this->pending[$key][] = $suspension = Scheduler::createSuspension();
+            $this->pending[$key][] = $suspension = Scheduler::getSuspension();
 
             $suspension->suspend();
         }
@@ -219,7 +219,7 @@ public function waitForPending(string|int $key): void
             return;
         }
 
-        $suspension = Scheduler::createSuspension();
+        $suspension = Scheduler::getSuspension();
         $this->waits[$key][] = $suspension;
         $suspension->suspend();
     }

src/Psl/Async/Scheduler.php

@@ -27,11 +27,11 @@ private function __construct()
     /**
      * Create an object used to suspend and resume execution, either within a fiber or from {main}.
      *
-     * @see EventLoop::createSuspension()
+     * @see EventLoop::getSuspension()
      */
-    public static function createSuspension(): Suspension
+    public static function getSuspension(): Suspension
     {
-        return EventLoop::createSuspension();
+        return EventLoop::getSuspension();
     }
 
     /**

src/Psl/Async/Semaphore.php

@@ -62,7 +62,7 @@ public function __construct(
     public function waitFor(mixed $input): mixed
     {
         if ($this->ingoing === $this->concurrencyLimit) {
-            $this->pending[] = $suspension = Scheduler::createSuspension();
+            $this->pending[] = $suspension = Scheduler::getSuspension();
 
             $suspension->suspend();
         }
@@ -166,7 +166,7 @@ public function waitForPending(): void
             return;
         }
 
-        $suspension = Scheduler::createSuspension();
+        $suspension = Scheduler::getSuspension();
         $this->waits[] = $suspension;
         $suspension->suspend();
     }

src/Psl/Async/Sequence.php

@@ -54,7 +54,7 @@ public function __construct(
     public function waitFor(mixed $input): mixed
     {
         if ($this->ingoing) {
-            $this->pending[] = $suspension = Scheduler::createSuspension();
+            $this->pending[] = $suspension = Scheduler::getSuspension();
 
             $suspension->suspend();
         }
@@ -136,7 +136,7 @@ public function waitForPending(): void
             return;
         }
 
-        $suspension = Scheduler::createSuspension();
+        $suspension = Scheduler::getSuspension();
         $this->waits[] = $suspension;
         $suspension->suspend();
     }

src/Psl/Async/later.php

@@ -13,7 +13,7 @@
  */
 function later(): void
 {
-    $suspension = Scheduler::createSuspension();
+    $suspension = Scheduler::getSuspension();
 
     Scheduler::defer(static fn () => $suspension->resume());
 

src/Psl/Async/sleep.php

@@ -9,7 +9,7 @@
  */
 function sleep(float $seconds): void
 {
-    $suspension = Scheduler::createSuspension();
+    $suspension = Scheduler::getSuspension();
     $watcher = Scheduler::delay($seconds, static fn () => $suspension->resume(null));
 
     try {

src/Psl/IO/Internal/ResourceHandle.php

@@ -131,7 +131,7 @@ public function write(string $bytes, ?float $timeout = null): int
     {
         // there's a pending read operation, wait for it.
         if ($this->writing) {
-            $suspension = Async\Scheduler::createSuspension();
+            $suspension = Async\Scheduler::getSuspension();
             $this->writeQueue[] = $suspension;
             $suspension->suspend();
         }
@@ -147,7 +147,7 @@ public function write(string $bytes, ?float $timeout = null): int
                 return $written;
             }
 
-            $this->writeSuspension = Async\Scheduler::createSuspension();
+            $this->writeSuspension = Async\Scheduler::getSuspension();
             /** @psalm-suppress MissingThrowsDocblock */
             Async\Scheduler::enable($this->writeWatcher);
             if (null !== $timeout) {
@@ -243,7 +243,7 @@ public function read(?int $max_bytes = null, ?float $timeout = null): string
     {
         // there's a pending read operation, wait for it.
         if ($this->reading) {
-            $suspension = Async\Scheduler::createSuspension();
+            $suspension = Async\Scheduler::getSuspension();
             $this->readQueue[] = $suspension;
             $suspension->suspend();
         }
@@ -258,7 +258,7 @@ public function read(?int $max_bytes = null, ?float $timeout = null): string
                 return $chunk;
             }
 
-            $this->readSuspension = Async\Scheduler::createSuspension();
+            $this->readSuspension = Async\Scheduler::getSuspension();
             /** @psalm-suppress MissingThrowsDocblock */
             Async\Scheduler::enable($this->readWatcher);
             if (null !== $timeout) {

src/Psl/Network/Internal/AbstractStreamServer.php

@@ -77,15 +77,15 @@ public function nextConnection(): Network\StreamSocketInterface
         }
 
         if (null !== $this->suspension) {
-            $suspension = Async\Scheduler::createSuspension();
+            $suspension = Async\Scheduler::getSuspension();
             $this->queue[] = $suspension;
             $suspension->suspend();
         } else {
             /** @psalm-suppress MissingThrowsDocblock */
             Async\Scheduler::enable($this->watcher);
         }
 
-        $this->suspension = Async\Scheduler::createSuspension();
+        $this->suspension = Async\Scheduler::getSuspension();
 
         try {
             /** @var resource $stream */

src/Psl/Network/Internal/socket_connect.php

@@ -37,7 +37,7 @@ function socket_connect(string $uri, array $context = [], ?float $timeout = null
             throw new Exception\RuntimeException('Failed to connect to client "' . $uri . '".', $errno);
         }
 
-        $suspension = Async\Scheduler::createSuspension();
+        $suspension = Async\Scheduler::getSuspension();
 
         $write_watcher = '';
         $timeout_watcher = '';