mpyw / co

src/Internal/YieldableUtils.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
      */
     public static function getApplier($yielded, array $yieldables, callable $next = null)
     {
-        return function (array $results) use ($yielded, $yieldables, $next) {
+        return function(array $results) use ($yielded, $yieldables, $next) {
             foreach ($results as $hash => $resolved) {
                 $current = &$yielded;
                 foreach ($yieldables[$hash]['keylist'] as $key) {
@@ -93,7 +93,7 @@ 
      */
     public static function safePromise(PromiseInterface $promise)
     {
-        return $promise->then(null, function ($value) {
+        return $promise->then(null, function($value) {
             if (TypeUtils::isFatalThrowable($value)) {
                 throw $value;
             }

src/Co.php

Spacing +3 added lines, -3 removed lines

@@ -164,7 +164,7 @@ 
                 YieldableUtils::getApplier($returned, $yieldables, [$deferred, 'resolve']),
                 [$deferred, 'reject']
             )
-            ->then(function () use ($yieldables, $deferred) {
+            ->then(function() use ($yieldables, $deferred) {
                 $this->runners = array_diff_key($this->runners, $yieldables);
                 return $deferred->promise();
             });
@@ -184,7 +184,7 @@ 
         // Check delay request yields
         if ($gc->key() === CoInterface::DELAY) {
             return $this->pool->addDelay($gc->current())
-            ->then(function () use ($gc) {
+            ->then(function() use ($gc) {
                 $gc->send(null);
                 return $this->processGeneratorContainer($gc);
             });
@@ -205,7 +205,7 @@ 
         ->then(
             YieldableUtils::getApplier($yielded, $yieldables, [$gc, 'send']),
             [$gc, 'throw_']
-        )->then(function () use ($gc, $yieldables) {
+        )->then(function() use ($gc, $yieldables) {
             // Continue
             $this->runners = array_diff_key($this->runners, $yieldables);
             return $this->processGeneratorContainer($gc);

src/Internal/CoOption.php

Spacing +2 added lines, -2 removed lines

@@ -90,7 +90,7 @@ 
     public function offsetGet($offset)
     {
         if (!isset($this->options[$offset])) {
-            throw new \DomainException('Undefined field: ' + $offset);
+            throw new \DomainException('Undefined field: ' +$offset);
         }
         return $this->options[$offset];
     }
@@ -130,7 +130,7 @@ 
             if ($key === 'autoschedule' && !defined('CURLMOPT_MAX_TOTAL_CONNECTIONS')) {
                 throw new \OutOfBoundsException('"autoschedule" can be used only on PHP 7.0.7 or later.');
             }
-            $validator = [__CLASS__, 'validate' . self::$types[$key]];
+            $validator = [__CLASS__, 'validate'.self::$types[$key]];
             $options[$key] = $validator($key, $value);
         }
         return $options;

src/Internal/ManualScheduler.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
         $errno = curl_multi_add_handle($this->mh, $ch);
         if ($errno !== CURLM_OK) {
             // @codeCoverageIgnoreStart
-            $msg = curl_multi_strerror($errno) . ": $ch";
+            $msg = curl_multi_strerror($errno).": $ch";
             $deferred && $deferred->reject(new \RuntimeException($msg));
             return;
             // @codeCoverageIgnoreEnd

src/Internal/AutoScheduler.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         $errno = curl_multi_add_handle($this->mh, $ch);
         if ($errno !== CURLM_OK) {
             // @codeCoverageIgnoreStart
-            $msg = curl_multi_strerror($errno) . ": $ch";
+            $msg = curl_multi_strerror($errno).": $ch";
             $deferred->reject(new \RuntimeException($msg));
             return $deferred->promise();
             // @codeCoverageIgnoreEnd