aboutsummaryrefslogtreecommitdiffhomepage
path: root/assets/php/vendor/react/event-loop/examples/12-generate-yes.php
diff options
context:
space:
mode:
Diffstat (limited to 'assets/php/vendor/react/event-loop/examples/12-generate-yes.php')
-rwxr-xr-xassets/php/vendor/react/event-loop/examples/12-generate-yes.php41
1 files changed, 0 insertions, 41 deletions
diff --git a/assets/php/vendor/react/event-loop/examples/12-generate-yes.php b/assets/php/vendor/react/event-loop/examples/12-generate-yes.php
deleted file mode 100755
index ebc2beb..0000000
--- a/assets/php/vendor/react/event-loop/examples/12-generate-yes.php
+++ /dev/null
@@ -1,41 +0,0 @@
-<?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();