cloverphp/async

async

v0.0.1 2025-09-29 08:28 UTC

Requires

• php: ^8.2

Requires (Dev)

• phpunit/phpunit: ^12.3

MIT

• Sushil Kumar

README

Example 1

Time based async task

use Clover\Utils\Timer;
use Clover\Utils\LoggerTrait;
use function Clover\Async\async;

class Demo {
    use LoggerTrait;

    public function run(): void {
        $this->log("Starting demo...");

        Timer::setTimeout(fn() => $this->log("Timeout fired after 1s"), 1000);

        $cancel = Timer::setInterval(fn() => $this->log("Interval tick every 500ms"), 500);

        // cancel interval after 3 seconds
        Timer::setTimeout(fn() => $cancel(), 3000);
    }
}

$demo = new Demo();
$demo->run();

Example 2

Promise based HTTP calling.

use Clover\Http\HttpClient;
use function Clover\Async\{async, await};

$client = new HttpClient();

$router->get('/users', async(function ($req, $res) use ($client) {
    try {
        $response = await($client->fetch("https://jsonplaceholder.typicode.com/users/1"));
        $res->json($response->json());
    } catch (\Throwable $e) {
        $res->status(500)->send("Error: " . $e->getMessage());
    } finally {
        log("Route /users finished");
    }
}));

Example 3

Async/Await Promise

use function Clover\Async\{async, await};
use Clover\Async\Http\HttpClient;

$client = new HttpClient();

$router->get('/users', async(function ($req, $res) use ($client) {
    try {
        $json = await($client->fetch("https://jsonplaceholder.typicode.com/users/1"));
        $res->json(json_decode($json, true));
    } catch (\Throwable $e) {
        $res->status(500)->send("Error: " . $e->getMessage());
    } finally {
        log("Route /users finished");
    }
}));