Update examples to use Stream v0.6 API

README.md

@@ -501,16 +501,6 @@ $promise->cancel();
 Calling `cancel()` on a pending promise will cancel the underlying DNS lookup
 and/or the underlying TCP/IP connection and reject the resulting promise.
 
-The legacy `Connector` class can be used for backwards-compatiblity reasons.
-It works very much like the newer `DnsConnector` but instead has to be
-set up like this:
-
-```php
-$connector = new React\SocketClient\Connector($loop, $dns);
-
-$connector->connect('www.google.com:80')->then($callback);
-```
-
 > Advanced usage: Internally, the `DnsConnector` relies on a `Resolver` to
 look up the IP address for the given hostname.
 It will then replace the hostname in the destination URI with this IP and

composer.json

@@ -19,6 +19,7 @@
     "require-dev": {
         "clue/block-react": "^1.1",
         "react/socket": "^0.5",
-        "phpunit/phpunit": "~4.8"
+        "phpunit/phpunit": "~4.8",
+        "react/stream": "^0.6"
     }
 }

examples/03-netcat.php

@@ -3,7 +3,8 @@
 use React\EventLoop\Factory;
 use React\SocketClient\Connector;
 use React\SocketClient\ConnectionInterface;
-use React\Stream\Stream;
+use React\Stream\ReadableResourceStream;
+use React\Stream\WritableResourceStream;
 
 require __DIR__ . '/../vendor/autoload.php';
 
@@ -15,12 +16,10 @@
 $loop = Factory::create();
 $connector = new Connector($loop);
 
-$stdin = new Stream(STDIN, $loop);
+$stdin = new ReadableResourceStream(STDIN, $loop);
 $stdin->pause();
-$stdout = new Stream(STDOUT, $loop);
-$stdout->pause();
-$stderr = new Stream(STDERR, $loop);
-$stderr->pause();
+$stdout = new WritableResourceStream(STDOUT, $loop);
+$stderr = new WritableResourceStream(STDERR, $loop);
 
 $stderr->write('Connecting' . PHP_EOL);
 

examples/04-web.php

@@ -3,7 +3,7 @@
 use React\EventLoop\Factory;
 use React\SocketClient\ConnectionInterface;
 use React\SocketClient\Connector;
-use React\Stream\Stream;
+use React\Stream\WritableResourceStream;
 
 require __DIR__ . '/../vendor/autoload.php';
 
@@ -36,8 +36,7 @@
     $resource .= '?' . $parts['query'];
 }
 
-$stdout = new Stream(STDOUT, $loop);
-$stdout->pause();
+$stdout = new WritableResourceStream(STDOUT, $loop);
 
 $connector->connect($target)->then(function (ConnectionInterface $connection) use ($resource, $host, $stdout) {
     $connection->pipe($stdout);