parallel/examples/worker/FetchTask.php

<?php declare(strict_types=1);

namespace App\Worker;

use Amp\Cancellation;
use Amp\Parallel\Worker\Task;
use Amp\Sync\Channel;

/**
 * @template-implements Task<string, never, never>
 */
final class FetchTask implements Task
{
    private string $url;

    public function __construct(string $url)
    {
        $this->url = $url;
    }

    public function run(Channel $channel, Cancellation $cancellation): mixed
    {
        return \file_get_contents($this->url);
    }
}