Async Concurrency Recipes

use Symfony\Component\HttpFoundation\Request;
use Glueful\Controllers\BaseController;
use Glueful\Http\Response;

$router->get('/dashboard', [DashboardController::class, 'show'])
    ->middleware(['async']);

class DashboardController extends BaseController
{
    public function show(Request $request)
    {
        $users = async(fn() => $this->repo->recentUsers());
        $stats = async(fn() => $this->analytics->summary());
        $news  = async(fn() => $this->news->latest());

        [$u, $s, $n] = await_all([$users, $stats, $news]);
        return Response::success(compact('u', 's', 'n'));
    }
}

$result = await_race([
    async(fn() => $this->cache->getFallback()),
    async(fn() => $this->service->fetchFresh()),
]);

$token = cancellation_token();

$task = async(function() use ($token) {
    while (!$token->isCancelled()) {
        // do incremental work
        async_sleep(0.05, $token);
    }

    // cleanup if needed
});

// cancel from another place (timeout/user action)
$token->cancel();

try {
    await($task);
} catch (\Throwable $e) {
    // handle cancellation or failure
}

use Glueful\Async\Contracts\Http\HttpClient;
use Glueful\Controllers\BaseController;
use Glueful\Http\Response;

class FeedController extends BaseController
{
    public function __construct(private HttpClient $http) {}

    public function index()
    {
        $feeds = [
            'a' => 'https://api.example.com/a',
            'b' => 'https://api.example.com/b',
            'c' => 'https://api.example.com/c',
        ];

        $tasks = [];
        foreach ($feeds as $key => $url) {
            $tasks[$key] = async(fn() => $this->http->get($url));
        }

        $responses = await_all($tasks);
        $payload = [];
        foreach ($responses as $k => $resp) {
            $payload[$k] = $resp->json();
        }

        return Response::success($payload);
    }
}