cubiche / async

Promise/Promises.php

Spacing +8 added lines, -8 removed lines

@@ -79,7 +79,7 @@ 
          */
         foreach ($promises as $key => $promise) {
             $promise->then(
-                function ($value) use ($deferred, &$results, $map, $key, &$pending) {
+                function($value) use ($deferred, &$results, $map, $key, &$pending) {
                     if ($map !== null) {
                         $value = $map($value);
                     }
@@ -89,7 +89,7 @@ 
                         $deferred->resolve($results);
                     }
                 },
-                function ($reason) use ($deferred) {
+                function($reason) use ($deferred) {
                     $deferred->reject($reason);
                 }
             );
@@ -109,18 +109,18 @@ 
     {
         $deferred = self::defer();
         $timer = $loop->timeout(
-            function () use ($promise, $deferred, $time) {
+            function() use ($promise, $deferred, $time) {
                 $deferred->reject(new TimeoutException($time));
             },
             $time
         );
 
         $promise->then(
-            function ($value = null) use ($deferred, $timer) {
+            function($value = null) use ($deferred, $timer) {
                 $timer->cancel();
                 $deferred->resolve($value);
             },
-            function ($reason = null) use ($deferred, $timer) {
+            function($reason = null) use ($deferred, $timer) {
                 $timer->cancel();
                 $deferred->reject($reason);
             }
@@ -147,14 +147,14 @@ 
         }
 
         $promise->then(
-            function ($value = null) use (&$result) {
+            function($value = null) use (&$result) {
                 $result = $value;
             },
-            function ($reason = null) use (&$rejectionReason) {
+            function($reason = null) use (&$rejectionReason) {
                 $rejectionReason = $reason;
             }
         )->always(
-            function () use ($loop) {
+            function() use ($loop) {
                 $loop->stop();
             }
         );

Promise/AbstractPromise.php

Spacing +2 added lines, -2 removed lines

@@ -31,11 +31,11 @@
      */
     public function always(callable $onFulfilledOrRejected, callable $onNotify = null)
     {
-        return $this->then(function ($value) use ($onFulfilledOrRejected) {
+        return $this->then(function($value) use ($onFulfilledOrRejected) {
             $onFulfilledOrRejected($value);
 
             return $value;
-        }, function ($reason) use ($onFulfilledOrRejected) {
+        }, function($reason) use ($onFulfilledOrRejected) {
             $onFulfilledOrRejected($reason);
         }, $onNotify);
     }

Promise/FulfilledPromise.php

Doc Comments +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
     /**
      * @param callable $onFulfilled
      *
-     * @return mixed
+     * @return PromiseInterface
      */
     private function resolveActual(callable $onFulfilled)
     {

Tests/Units/Promise/FulfilledPromiseTests.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
     public function testConstruct()
     {
         $this
-            ->exception(function () {
+            ->exception(function() {
                 $this->newTestedInstance($this->newDefaultTestedInstance());
             })
             ->isInstanceOf(\InvalidArgumentException::class)

Tests/Units/Promise/ObservableResolverTests.php

Spacing +2 added lines, -2 removed lines

@@ -24,7 +24,7 @@ 
     {
         parent::testResolve();
 
-        $this->innerFailureTest(function (callable $resolveCallback, callable $rejectCallback) {
+        $this->innerFailureTest(function(callable $resolveCallback, callable $rejectCallback) {
             /** @var \Cubiche\Core\Async\Promise\ObservableResolver $resolver */
             $resolver = $this->newTestedInstance($resolveCallback, $rejectCallback);
             $resolver->resolve();
@@ -38,7 +38,7 @@ 
     {
         parent::testNotify();
 
-        $this->innerFailureTest(function (callable $notifyCallback, callable $rejectCallback) {
+        $this->innerFailureTest(function(callable $notifyCallback, callable $rejectCallback) {
             /** @var \Cubiche\Core\Async\Promise\ObservableResolver $resolver */
             $resolver = $this->newTestedInstance(null, $rejectCallback, $notifyCallback);
             $resolver->notify();

Tests/Units/Promise/DoneResolverTests.php

Spacing +4 added lines, -4 removed lines

@@ -24,7 +24,7 @@ 
     {
         parent::testResolve();
 
-        $this->innerFailureTest(function (callable $onFulfilled) {
+        $this->innerFailureTest(function(callable $onFulfilled) {
             /** @var \Cubiche\Core\Async\Promise\DoneResolver $resolver */
             $resolver = $this->newTestedInstance($onFulfilled);
             $resolver->resolve();
@@ -38,7 +38,7 @@ 
     {
         parent::testReject();
 
-        $this->innerFailureTest(function (callable $onRejected) {
+        $this->innerFailureTest(function(callable $onRejected) {
             /** @var \Cubiche\Core\Async\Promise\DoneResolver $resolver */
             $resolver = $this->newTestedInstance(null, $onRejected);
             $resolver->reject();
@@ -52,7 +52,7 @@ 
     {
         parent::testNotify();
 
-        $this->innerFailureTest(function (callable $onNotify) {
+        $this->innerFailureTest(function(callable $onNotify) {
             /** @var \Cubiche\Core\Async\Promise\DoneResolver $resolver */
             $resolver = $this->newTestedInstance(null, null, $onNotify);
             $resolver->notify();
@@ -69,7 +69,7 @@ 
                 $reason = new \Exception(),
                 $callback = $this->delegateMockWithException($reason)
             )
-            ->exception(function () use ($when, $callback) {
+            ->exception(function() use ($when, $callback) {
                 $when($callback);
             })
         ;

Tests/Units/Promise/ThenResolverTests.php

Spacing +3 added lines, -3 removed lines

@@ -36,7 +36,7 @@ 
                 $onFulfilledPromise = $this->delegateMock(),
                 $onNotifyPromise = $this->delegateMock()
             )
-            ->when(function () use ($resolver, $onFulfilledPromise, $onNotifyPromise) {
+            ->when(function() use ($resolver, $onFulfilledPromise, $onNotifyPromise) {
                 $resolver->resolve();
                 $resolver->promise()->then($onFulfilledPromise, null, $onNotifyPromise);
             })
@@ -71,7 +71,7 @@ 
                 $resolver = $this->newTestedInstance($onFulfilled),
                 $onRejectedPromise = $this->delegateMock()
             )
-            ->when(function () use ($resolver, $onRejectedPromise) {
+            ->when(function() use ($resolver, $onRejectedPromise) {
                 $resolver->resolve();
                 $resolver->promise()->then(null, $onRejectedPromise);
             })
@@ -97,7 +97,7 @@ 
                 $resolver = $this->newTestedInstance(null, $onRejected),
                 $onRejectedPromise = $this->delegateMock()
             )
-            ->when(function () use ($resolver, $onRejectedPromise) {
+            ->when(function() use ($resolver, $onRejectedPromise) {
                 $resolver->reject();
                 $resolver->promise()->then(null, $onRejectedPromise);
             })

Promise/Deferred.php

Spacing +3 added lines, -3 removed lines

@@ -42,13 +42,13 @@
     {
         if ($this->promise === null) {
             $this->promise = new Promise(
-                function (callable $resolveCallback) {
+                function(callable $resolveCallback) {
                     $this->resolveCallback = $resolveCallback;
                 },
-                function (callable $rejectCallback) {
+                function(callable $rejectCallback) {
                     $this->rejectCallback = $rejectCallback;
                 },
-                function (callable $notifyCallback) {
+                function(callable $notifyCallback) {
                     $this->notifyCallback = $notifyCallback;
                 }
             );

Promise/ThenResolver.php

Spacing +3 added lines, -3 removed lines

@@ -66,11 +66,11 @@
     {
         $value = $this->callResolveCallback($value);
         if ($value instanceof PromiseInterface) {
-            $value->done(function ($actual) {
+            $value->done(function($actual) {
                 $this->deferred->resolve($actual);
-            }, function ($reason) {
+            }, function($reason) {
                 $this->deferred->reject($reason);
-            }, function ($state) {
+            }, function($state) {
                 $this->deferred->notify($state);
             });
         } else {