Merge pull request #71 from clue-labs/default-loop

Simplify usage by supporting new default loop

Author: clue

README.md

@@ -58,14 +58,11 @@ Once [installed](#install), you can use the following code to access the
 Docker API of your local docker daemon:
 
 ```php
-$loop = React\EventLoop\Factory::create();
-$client = new Clue\React\Docker\Client($loop);
+$client = new Clue\React\Docker\Client();
 
 $client->imageSearch('clue')->then(function (array $images) {
     var_dump($images);
 });
-
-$loop->run();
 ```
 
 See also the [examples](examples).
@@ -75,23 +72,26 @@ See also the [examples](examples).
 ### Client
 
 The `Client` is responsible for assembling and sending HTTP requests to the Docker Engine API.
-It uses an HTTP client bound to the main [`EventLoop`](https://github.com/reactphp/event-loop#usage)
-in order to handle async requests:
 
 ```php
-$loop = React\EventLoop\Factory::create();
-$client = new Clue\React\Docker\Client($loop);
+$client = new Clue\React\Docker\Client();
 ```
 
+This class takes an optional `LoopInterface|null $loop` parameter that can be used to
+pass the event loop instance to use for this object. You can use a `null` value
+here in order to use the [default loop](https://github.com/reactphp/event-loop#loop).
+This value SHOULD NOT be given unless you're sure you want to explicitly use a
+given event loop instance.
+
 If your Docker Engine API is not accessible using the default `unix:///var/run/docker.sock`
 Unix domain socket path, you may optionally pass an explicit URL like this:
 
-```
+```php
 // explicitly use given UNIX socket path
-$client = new Clue\React\Docker\Client($loop, 'unix:///var/run/docker.sock');
+$client = new Clue\React\Docker\Client(null, 'unix:///var/run/docker.sock');
 
 // or connect via TCP/IP to a remote Docker Engine API
-$client = new Clue\React\Docker\Client($loop, 'http://10.0.0.2:8000/');
+$client = new Clue\React\Docker\Client(null, 'http://10.0.0.2:8000/');
 ```
 
 #### Commands
@@ -154,13 +154,12 @@ The resulting blocking code could look something like this:
 ```php
 use Clue\React\Block;
 
-$loop = React\EventLoop\Factory::create();
-$client = new Clue\React\Docker\Client($loop);
+$client = new Clue\React\Docker\Client();
 
 $promise = $client->imageInspect('busybox');
 
 try {
-    $results = Block\await($promise, $loop);
+    $results = Block\await($promise, Loop::get());
     // resporesults successfully received
 } catch (Exception $e) {
     // an error occured while performing the request
@@ -175,7 +174,7 @@ $promises = array(
     $client->imageInspect('ubuntu'),
 );
 
-$inspections = Block\awaitAll($promises, $loop);
+$inspections = Block\awaitAll($promises, Loop::get());
 ```
 
 Please refer to [clue/reactphp-block](https://github.com/clue/reactphp-block#readme) for more details.

composer.json

@@ -19,12 +19,12 @@
     "require": {
         "php": ">=5.3",
         "clue/json-stream": "^0.1",
-        "react/event-loop": "^1.0 || ^0.5 || ^0.4 || ^0.3",
-        "react/http": "^1.0",
+        "react/event-loop": "^1.2",
+        "react/http": "^1.4",
         "react/promise": "^2.0 || ^1.1",
         "react/promise-stream": "^1.0",
-        "react/socket": "^1.0",
-        "react/stream": "^1.0",
+        "react/socket": "^1.8",
+        "react/stream": "^1.2",
         "rize/uri-template": "^0.3"
     },
     "require-dev": {

examples/archive.php

@@ -15,8 +15,7 @@
 $path = isset($argv[2]) ? $argv[2] : '/etc/passwd';
 echo 'Container "' . $container . '" dumping "' . $path . '" (pass as arguments to this example)' . PHP_EOL;
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 $stream = $client->containerArchiveStream($container, $path);
 
@@ -43,5 +42,3 @@
 });
 
 $stream->pipe($tar);
-
-$loop->run();

examples/attach-stream.php

@@ -14,8 +14,7 @@
 $container = isset($argv[1]) ? $argv[1] : 'foo';
 echo 'Dumping output of container "' . $container . '" (pass as argument to this example)' . PHP_EOL;
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 // use caret notation for any control characters except \t, \r and \n
 $caret = new Encoder("\t\r\n");
@@ -33,5 +32,3 @@
 $stream->on('close', function () {
     echo 'CLOSED' . PHP_EOL;
 });
-
-$loop->run();

examples/benchmark-attach.php

@@ -11,6 +11,7 @@
 // $ docker run -i --rm --log-driver=none busybox dd if=/dev/zero bs=1M count=1000 status=none | dd of=/dev/null
 
 use Clue\React\Docker\Client;
+use React\EventLoop\Loop;
 
 require __DIR__ . '/../vendor/autoload.php';
 
@@ -26,8 +27,7 @@
     $cmd = array_slice($argv, 2);
 }
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 $client->containerCreate(array(
     'Image' => $image,
@@ -38,11 +38,11 @@
             'Type' => 'none'
         )
     )
-))->then(function ($container) use ($client, $loop) {
+))->then(function ($container) use ($client) {
     $stream = $client->containerAttachStream($container['Id'], false, true);
 
     // we're creating the container without a log, so first wait for attach stream before starting
-    $loop->addTimer(0.1, function () use ($client, $container) {
+    Loop::addTimer(0.1, function () use ($client, $container) {
         $client->containerStart($container['Id'])->then(null, 'printf');
     });
 
@@ -62,5 +62,3 @@
         echo 'Received ' . $bytes . ' bytes in ' . round($time, 1) . 's => ' . round($bytes / $time / 1000000, 1) . ' MB/s' . PHP_EOL;
     });
 }, 'printf');
-
-$loop->run();

examples/benchmark-exec.php

@@ -29,8 +29,7 @@
     $cmd = array_slice($argv, 2);
 }
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 $client->execCreate($container, $cmd)->then(function ($info) use ($client) {
     $stream = $client->execStartStream($info['Id'], true);
@@ -50,5 +49,3 @@
         echo 'Received ' . $bytes . ' bytes in ' . round($time, 1) . 's => ' . round($bytes / $time / 1000000, 1) . ' MB/s' . PHP_EOL;
     });
 }, 'printf');
-
-$loop->run();

examples/events.php

@@ -7,8 +7,7 @@
 
 require __DIR__ . '/../vendor/autoload.php';
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 // get a list of all events that happened up until this point
 // expect this list to be limited to the last 64 (or so) events
@@ -25,5 +24,3 @@
 });
 
 $stream->on('error', 'printf');
-
-$loop->run();

examples/exec-inspect.php

@@ -18,8 +18,7 @@
     $cmd = array_slice($argv, 2);
 }
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 $client->execCreate($container, $cmd)->then(function ($info) use ($client) {
     echo 'Created with info: ' . json_encode($info) . PHP_EOL;
@@ -43,5 +42,3 @@
         echo 'Response: ' . $e->getResponse()->getBody() . PHP_EOL;
     }
 });
-
-$loop->run();

examples/exec-stream.php

@@ -4,6 +4,7 @@
 // displays the streaming output as it happens.
 
 use Clue\React\Docker\Client;
+use React\EventLoop\Loop;
 use React\Stream\WritableResourceStream;
 
 require __DIR__ . '/../vendor/autoload.php';
@@ -23,11 +24,10 @@
     $cmd = array_slice($argv, 2);
 }
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
-$out = new WritableResourceStream(STDOUT, $loop);
-$stderr = new WritableResourceStream(STDERR, $loop);
+$out = new WritableResourceStream(STDOUT);
+$stderr = new WritableResourceStream(STDERR);
 
 // unkown exit code by default
 $exit = 1;
@@ -56,6 +56,6 @@
     });
 }, 'printf');
 
-$loop->run();
+Loop::run();
 
 exit($exit);

examples/export.php

@@ -16,8 +16,7 @@
 $target = isset($argv[2]) ? $argv[2] : ($container . '.tar');
 echo 'Exporting whole container "' . $container . '" to "' . $target .'" (pass as arguments to this example)' . PHP_EOL;
 
-$loop = React\EventLoop\Factory::create();
-$client = new Client($loop);
+$client = new Client();
 
 $stream = $client->containerExportStream($container);
 
@@ -26,7 +25,5 @@
     echo 'ERROR requesting stream' . PHP_EOL . $e;
 });
 
-$out = new WritableResourceStream(fopen($target, 'w'), $loop);
+$out = new WritableResourceStream(fopen($target, 'w'));
 $stream->pipe($out);
-
-$loop->run();