$receiver * @var Channel\SenderInterface $sender */ [$receiver, $sender] = Channel\unbounded(); Async\Scheduler::delay(1, static function () use ($sender) { $sender->send('Hello, World!'); }); $message = $receiver->receive(); IO\write_error_line($message);