mpyw / co

examples/localhost/server.php

Braces +6 added lines, -3 removed lines

@@ -55,8 +55,9 @@ 
         $con = @stream_socket_accept($socket, -1);
         if (!$con) {
             $err = error_get_last(); // どーなんだこれ strerror(EINTR)
-            if (strpos($err["message"], "Interrupted system call") !== false)
-                continue;
+            if (strpos($err["message"], "Interrupted system call") !== false) {
+                            continue;
+            }
             fwrite(STDERR, "[Server] " . $err["message"] . "\n");
             exit(1);
         }
@@ -91,7 +92,9 @@ 
         parse_str(isset($parsed['query']) ? $parsed['query'] : '', $q);
         foreach ($endpoints as $endpoint => $action) {
             if ($parsed['path'] === $endpoint || $endpoint === '') {
-                if ($endpoint === '') $endpoint = '[Undefined]';
+                if ($endpoint === '') {
+                    $endpoint = '[Undefined]';
+                }
                 fwrite(STDERR, "Request: $parts[1]\n");
                 $action($con, $q);
                 exit(0);

src/Co.php

Braces +3 added lines, -1 removed lines

@@ -323,8 +323,10 @@
             // NOTE: DO NOT call curl_multi_remove_handle
             //       or curl_multi_add_handle while looping curl_multi_info_read!
             $entries = array();
-            do if ($entry = curl_multi_info_read($this->mh, $remains)) {
+            do {
+                if ($entry = curl_multi_info_read($this->mh, $remains)) {
                 $entries[] = $entry;
+            }
             } while ($remains);
             // Remove done and consume queue.
             foreach ($entries as $entry) {