<?php
require __DIR__ . '/../vendor/autoload.php';
// data can be given as first argument or defaults to "y"
$data = (isset($argv[1]) ? $argv[1] : 'y') . "\n";
// repeat data X times in order to fill around 200 KB
$data = str_repeat($data, round(200000 / strlen($data)));
$loop = React\EventLoop\Factory::create();
if (!defined('STDOUT') || stream_set_blocking(STDOUT, false) !== true) {
fwrite(STDERR, 'ERROR: Unable to set STDOUT non-blocking (not CLI or Windows?)' . PHP_EOL);
exit(1);
}
// write data to STDOUT whenever its write buffer accepts data
// for illustrations purpose only, should use react/stream instead
$loop->addWriteStream(STDOUT, function ($stdout) use ($loop, &$data) {
// try to write data
$r = fwrite($stdout, $data);
// nothing could be written despite being writable => closed
if ($r === 0) {
$loop->removeWriteStream($stdout);
fclose($stdout);
stream_set_blocking($stdout, true);
fwrite(STDERR, 'Stopped because STDOUT closed' . PHP_EOL);
return;
}
// implement a very simple ring buffer, unless everything has been written at once:
// everything written in this iteration will be appended for next iteration
if (isset($data[$r])) {
$data = substr($data, $r) . substr($data, 0, $r);
}
});
$loop->run();
|
Download
