diff --git a/‎src/functions.php
Lines changed: 3 additions & 3 deletions b/‎src/functions.php
Lines changed: 3 additions & 3 deletions
diff --git a/‎tests/AsyncTest.php
Lines changed: 6 additions & 6 deletions b/‎tests/AsyncTest.php
Lines changed: 6 additions & 6 deletions
diff --git a/‎tests/AwaitTest.php
Lines changed: 1 addition & 1 deletion b/‎tests/AwaitTest.php
Lines changed: 1 addition & 1 deletion
@@ -15,13 +15,13 @@
  *
  * @param callable(mixed ...$args):mixed $function
  * @param mixed ...$args Optional list of additional arguments that will be passed to the given `$function` as is
- * @return PromiseInterface<mixed>
+ * @return callable<PromiseInterface<mixed>>
  * @since 4.0.0
  * @see coroutine()
  */
-function async(callable $function, mixed ...$args): PromiseInterface
+function async(callable $function, mixed ...$args): callable
 {
-    return new Promise(function (callable $resolve, callable $reject) use ($function, $args): void {
+    return static fn (): PromiseInterface => new Promise(function (callable $resolve, callable $reject) use ($function, $args): void {
         $fiber = new \Fiber(function () use ($resolve, $reject, $function, $args): void {
             try {
                 $resolve($function(...$args));
 
@@ -15,7 +15,7 @@ public function testAsyncReturnsPendingPromise()
     {
         $promise = async(function () {
             return 42;
-        });
+        })();
 
         $promise->then($this->expectCallableNever(), $this->expectCallableNever());
     }
@@ -24,7 +24,7 @@ public function testAsyncReturnsPromiseThatFulfillsWithValueWhenCallbackReturns(
     {
         $promise = async(function () {
             return 42;
-        });
+        })();
 
         $value = await($promise);
 
@@ -35,7 +35,7 @@ public function testAsyncReturnsPromiseThatRejectsWithExceptionWhenCallbackThrow
     {
         $promise = async(function () {
             throw new \RuntimeException('Foo', 42);
-        });
+        })();
 
         $this->expectException(\RuntimeException::class);
         $this->expectExceptionMessage('Foo');
@@ -51,7 +51,7 @@ public function testAsyncReturnsPromiseThatFulfillsWithValueWhenCallbackReturnsA
             });
 
             return await($promise);
-        });
+        })();
 
         $value = await($promise);
 
@@ -66,15 +66,15 @@ public function testAsyncReturnsPromiseThatFulfillsWithValueWhenCallbackReturnsA
             });
 
             return await($promise);
-        });
+        })();
 
         $promise2 = async(function () {
             $promise = new Promise(function ($resolve) {
                 Loop::addTimer(0.11, fn () => $resolve(42));
             });
 
             return await($promise);
-        });
+        })();
 
         $time = microtime(true);
         $values = await(all([$promise1, $promise2]));
 
@@ -160,6 +160,6 @@ public function testAwaitShouldNotCreateAnyGarbageReferencesForPromiseRejectedWi
     public function provideAwaiters(): iterable
     {
         yield 'await' => [static fn (React\Promise\PromiseInterface $promise): mixed => React\Async\await($promise)];
-        yield 'async' => [static fn (React\Promise\PromiseInterface $promise): mixed => React\Async\await(React\Async\async(static fn(): mixed => $promise))];
+        yield 'async' => [static fn (React\Promise\PromiseInterface $promise): mixed => React\Async\await(React\Async\async(static fn(): mixed => $promise)())];
     }
 }