mpyw / co

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) {

Spacing +7 added lines, -7 removed lines

@@ -54,14 +54,14 @@
      *   - "async" (Co::async calls)
      */
     private $options = array();
-    private $mh;                          // curl_multi_init()
-    private $count = 0;                   // count(curl_multi_add_handle called)
-    private $queue = array();             // cURL resources over concurrency limits are temporalily stored here
-    private $tree = array();              // array<*Stack ID*, mixed>
-    private $values = array();            // array<*Stack ID*|*cURL ID*, Generator|resource<cURL>>
-    private $value_to_parent = array();   // array<*Stack ID*|*cURL ID*, *Stack ID*>
+    private $mh; // curl_multi_init()
+    private $count = 0; // count(curl_multi_add_handle called)
+    private $queue = array(); // cURL resources over concurrency limits are temporalily stored here
+    private $tree = array(); // array<*Stack ID*, mixed>
+    private $values = array(); // array<*Stack ID*|*cURL ID*, Generator|resource<cURL>>
+    private $value_to_parent = array(); // array<*Stack ID*|*cURL ID*, *Stack ID*>
     private $value_to_children = array(); // array<*Stack ID*, array<*Stack ID*|*cURL ID*, true>>
-    private $value_to_keylist = array();  // array<*Stack ID*|*cURL ID*, array<mixed>>
+    private $value_to_keylist = array(); // array<*Stack ID*|*cURL ID*, array<mixed>>
 
     /**
      * Override or get default settings.