$receiver * @var Channel\SenderInterface $sender */ [$receiver, $sender] = Channel\bounded(10); Async\Scheduler::defer(static function () use ($receiver) { try { while (true) { $receiver->receive(); } } catch (Channel\Exception\ClosedChannelException) { IO\write_error_line('[ receiver ]: completed.'); } }); for ($i = 0; $i < 10; $i++) { $file = File\open_read_only(__FILE__); while ($byte = $file->readAll(1)) { $sender->send($byte); } $file->close(); } IO\write_error_line('[ sender ]: completed.'); $sender->close(); return 0; });