Updated examples

examples/01-timers.php

@@ -1,15 +1,15 @@
 <?php
 
-require __DIR__ . '/../vendor/autoload.php';
+use React\EventLoop\Loop;
 
-$loop = React\EventLoop\Factory::create();
+require __DIR__ . '/../vendor/autoload.php';
 
-$loop->addTimer(0.8, function () {
+Loop::get()->addTimer(0.8, function () {
     echo 'world!' . PHP_EOL;
 });
 
-$loop->addTimer(0.3, function () {
+Loop::get()->addTimer(0.3, function () {
     echo 'hello ';
 });
 
-$loop->run();
+Loop::get()->run();

examples/02-periodic.php

@@ -1,16 +1,16 @@
 <?php
 
-require __DIR__ . '/../vendor/autoload.php';
+use React\EventLoop\Loop;
 
-$loop = React\EventLoop\Factory::create();
+require __DIR__ . '/../vendor/autoload.php';
 
-$timer = $loop->addPeriodicTimer(0.1, function () {
+$timer = Loop::get()->addPeriodicTimer(0.1, function () {
     echo 'tick!' . PHP_EOL;
 });
 
-$loop->addTimer(1.0, function () use ($loop, $timer) {
-    $loop->cancelTimer($timer);
+Loop::get()->addTimer(1.0, function () use ($timer) {
+    Loop::get()->cancelTimer($timer);
     echo 'Done' . PHP_EOL;
 });
 
-$loop->run();
+Loop::get()->run();

examples/03-ticks.php

@@ -1,15 +1,15 @@
 <?php
 
-require __DIR__ . '/../vendor/autoload.php';
+use React\EventLoop\Loop;
 
-$loop = React\EventLoop\Factory::create();
+require __DIR__ . '/../vendor/autoload.php';
 
-$loop->futureTick(function () {
+Loop::get()->futureTick(function () {
     echo 'b';
 });
-$loop->futureTick(function () {
+Loop::get()->futureTick(function () {
     echo 'c';
 });
 echo 'a';
 
-$loop->run();
+Loop::get()->run();

examples/04-signals.php

@@ -1,19 +1,19 @@
 <?php
 
+use React\EventLoop\Loop;
+
 require __DIR__ . '/../vendor/autoload.php';
 
 if (!defined('SIGINT')) {
     fwrite(STDERR, 'Not supported on your platform (ext-pcntl missing or Windows?)' . PHP_EOL);
     exit(1);
 }
 
-$loop = React\EventLoop\Factory::create();
-
-$loop->addSignal(SIGINT, $func = function ($signal) use ($loop, &$func) {
+Loop::get()->addSignal(SIGINT, $func = function ($signal) use (&$func) {
     echo 'Signal: ', (string)$signal, PHP_EOL;
-    $loop->removeSignal(SIGINT, $func);
+    Loop::get()->removeSignal(SIGINT, $func);
 });
 
 echo 'Listening for SIGINT. Use "kill -SIGINT ' . getmypid() . '" or CTRL+C' . PHP_EOL;
 
-$loop->run();
+Loop::get()->run();

examples/11-consume-stdin.php

@@ -1,6 +1,6 @@
 <?php
 
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
@@ -9,16 +9,14 @@
     exit(1);
 }
 
-$loop = Factory::create();
-
 // read everything from STDIN and report number of bytes
 // for illustration purposes only, should use react/stream instead
-$loop->addReadStream(STDIN, function ($stream) use ($loop) {
+Loop::get()->addReadStream(STDIN, function ($stream) {
     $chunk = fread($stream, 64 * 1024);
 
     // reading nothing means we reached EOF
     if ($chunk === '') {
-        $loop->removeReadStream($stream);
+        Loop::get()->removeReadStream($stream);
         stream_set_blocking($stream, true);
         fclose($stream);
         return;
@@ -27,4 +25,4 @@
     echo strlen($chunk) . ' bytes' . PHP_EOL;
 });
 
-$loop->run();
+Loop::get()->run();

examples/12-generate-yes.php

@@ -1,5 +1,7 @@
 <?php
 
+use React\EventLoop\Loop;
+
 require __DIR__ . '/../vendor/autoload.php';
 
 // data can be given as first argument or defaults to "y"
@@ -8,22 +10,20 @@
 // 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) {
+Loop::get()->addWriteStream(STDOUT, function ($stdout) use (&$data) {
     // try to write data
     $r = fwrite($stdout, $data);
 
     // nothing could be written despite being writable => closed
     if ($r === 0) {
-        $loop->removeWriteStream($stdout);
+        Loop::get()->removeWriteStream($stdout);
         fclose($stdout);
         stream_set_blocking($stdout, true);
         fwrite(STDERR, 'Stopped because STDOUT closed' . PHP_EOL);
@@ -38,4 +38,4 @@
     }
 });
 
-$loop->run();
+Loop::get()->run();

examples/13-http-client-blocking.php

@@ -1,11 +1,9 @@
 <?php
 
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = Factory::create();
-
 // connect to www.google.com:80 (blocking call!)
 // for illustration purposes only, should use react/socket instead
 $stream = stream_socket_client('tcp://www.google.com:80');
@@ -18,18 +16,18 @@
 fwrite($stream, "GET / HTTP/1.1\r\nHost: www.google.com\r\nConnection: close\r\n\r\n");
 
 // wait for HTTP response
-$loop->addReadStream($stream, function ($stream) use ($loop) {
+Loop::get()->addReadStream($stream, function ($stream) {
     $chunk = fread($stream, 64 * 1024);
 
     // reading nothing means we reached EOF
     if ($chunk === '') {
         echo '[END]' . PHP_EOL;
-        $loop->removeReadStream($stream);
+        Loop::get()->removeReadStream($stream);
         fclose($stream);
         return;
     }
 
     echo $chunk;
 });
 
-$loop->run();
+Loop::get()->run();

examples/14-http-client-async.php

@@ -1,11 +1,10 @@
 <?php
 
 use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = Factory::create();
-
 // resolve hostname before establishing TCP/IP connection (resolving DNS is still blocking here)
 // for illustration purposes only, should use react/socket or react/dns instead!
 $ip = gethostbyname('www.google.com');
@@ -24,14 +23,14 @@
 
 // print progress every 10ms
 echo 'Connecting';
-$timer = $loop->addPeriodicTimer(0.01, function () {
+$timer = Loop::get()->addPeriodicTimer(0.01, function () {
     echo '.';
 });
 
 // wait for connection success/error
-$loop->addWriteStream($stream, function ($stream) use ($loop, $timer) {
-    $loop->removeWriteStream($stream);
-    $loop->cancelTimer($timer);
+Loop::get()->addWriteStream($stream, function ($stream) use ($timer) {
+    Loop::get()->removeWriteStream($stream);
+    Loop::get()->cancelTimer($timer);
 
     // check for socket error (connection rejected)
     if (stream_socket_get_name($stream, true) === false) {
@@ -45,13 +44,13 @@
     fwrite($stream, "GET / HTTP/1.1\r\nHost: www.google.com\r\nConnection: close\r\n\r\n");
 
     // wait for HTTP response
-    $loop->addReadStream($stream, function ($stream) use ($loop) {
+    Loop::get()->addReadStream($stream, function ($stream) {
         $chunk = fread($stream, 64 * 1024);
 
         // reading nothing means we reached EOF
         if ($chunk === '') {
             echo '[END]' . PHP_EOL;
-            $loop->removeReadStream($stream);
+            Loop::get()->removeReadStream($stream);
             fclose($stream);
             return;
         }
@@ -60,4 +59,4 @@
     });
 });
 
-$loop->run();
+Loop::get()->run();

examples/21-http-server.php

@@ -1,8 +1,8 @@
 <?php
 
-require __DIR__ . '/../vendor/autoload.php';
+use React\EventLoop\Loop;
 
-$loop = React\EventLoop\Factory::create();
+require __DIR__ . '/../vendor/autoload.php';
 
 // start TCP/IP server on localhost:8080
 // for illustration purposes only, should use react/socket instead
@@ -13,24 +13,24 @@
 stream_set_blocking($server, false);
 
 // wait for incoming connections on server socket
-$loop->addReadStream($server, function ($server) use ($loop) {
+Loop::get()->addReadStream($server, function ($server) {
     $conn = stream_socket_accept($server);
     $data = "HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nHi\n";
-    $loop->addWriteStream($conn, function ($conn) use (&$data, $loop) {
+    Loop::get()->addWriteStream($conn, function ($conn) use (&$data) {
         $written = fwrite($conn, $data);
         if ($written === strlen($data)) {
             fclose($conn);
-            $loop->removeWriteStream($conn);
+            Loop::get()->removeWriteStream($conn);
         } else {
             $data = substr($data, $written);
         }
     });
 });
 
-$loop->addPeriodicTimer(5, function () {
+Loop::get()->addPeriodicTimer(5, function () {
     $memory = memory_get_usage() / 1024;
     $formatted = number_format($memory, 3).'K';
     echo "Current memory usage: {$formatted}\n";
 });
 
-$loop->run();
+Loop::get()->run();

examples/91-benchmark-ticks.php

@@ -1,15 +1,13 @@
 <?php
 
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = Factory::create();
-
 $n = isset($argv[1]) ? (int)$argv[1] : 1000 * 100;
 
 for ($i = 0; $i < $n; ++$i) {
-    $loop->futureTick(function () { });
+    Loop::get()->futureTick(function () { });
 }
 
-$loop->run();
+Loop::get()->run();

examples/92-benchmark-timers.php

@@ -1,15 +1,13 @@
 <?php
 
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = Factory::create();
-
 $n = isset($argv[1]) ? (int)$argv[1] : 1000 * 100;
 
 for ($i = 0; $i < $n; ++$i) {
-    $loop->addTimer(0, function () { });
+    Loop::get()->addTimer(0, function () { });
 }
 
-$loop->run();
+Loop::get()->run();

examples/93-benchmark-ticks-delay.php

@@ -1,22 +1,20 @@
 <?php
 
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = Factory::create();
-
 $ticks = isset($argv[1]) ? (int)$argv[1] : 1000 * 100;
-$tick = function () use (&$tick, &$ticks, $loop) {
+$tick = function () use (&$tick, &$ticks) {
     if ($ticks > 0) {
         --$ticks;
         //$loop->addTimer(0, $tick);
-        $loop->futureTick($tick);
+        Loop::get()->futureTick($tick);
     } else {
         echo 'done';
     }
 };
 
 $tick();
 
-$loop->run();
+Loop::get()->run();

examples/94-benchmark-timers-delay.php

@@ -1,22 +1,20 @@
 <?php
 
-use React\EventLoop\Factory;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = Factory::create();
-
 $ticks = isset($argv[1]) ? (int)$argv[1] : 1000 * 100;
-$tick = function () use (&$tick, &$ticks, $loop) {
+$tick = function () use (&$tick, &$ticks) {
     if ($ticks > 0) {
         --$ticks;
         //$loop->futureTick($tick);
-        $loop->addTimer(0, $tick);
+        Loop::get()->addTimer(0, $tick);
     } else {
         echo 'done';
     }
 };
 
 $tick();
 
-$loop->run();
+Loop::get()->run();