Demo Socket::end() in example

Author: clue

example/client.php

@@ -21,13 +21,21 @@
     });
 
     $n = 0;
-    $loop->addPeriodicTimer(2.0, function() use ($client, &$n) {
+    $tid = $loop->addPeriodicTimer(2.0, function() use ($client, &$n) {
         $client->send('tick' . ++$n);
     });
 
     // read input from STDIN and forward everything to server
-    $loop->addReadStream(STDIN, function () use ($client) {
-        $client->send(trim(fgets(STDIN, 2000)));
+    $loop->addReadStream(STDIN, function () use ($client, $loop, $tid) {
+        $msg = fgets(STDIN, 2000);
+        if ($msg === false) {
+            // EOF => flush client and stop perodic sending and waiting for input
+            $client->end();
+            $loop->cancelTimer($tid);
+            $loop->removeReadStream(STDIN);
+        } else {
+            $client->send(trim($msg));
+        }
     });
 }, function($error) {
     echo 'ERROR: ' . $error->getMessage() . PHP_EOL;