php-http / react-adapter

src/Promise.php

Spacing +5 added lines, -5 removed lines

@@ -71,15 +71,15 @@ 
     {
         $newPromise = new self($this->loop);
 
-        $onFulfilled = null !== $onFulfilled ? $onFulfilled : function (ResponseInterface $response) {
+        $onFulfilled = null !== $onFulfilled ? $onFulfilled : function(ResponseInterface $response) {
             return $response;
         };
 
-        $onRejected = null !== $onRejected ? $onRejected : function (Exception $exception) {
+        $onRejected = null !== $onRejected ? $onRejected : function(Exception $exception) {
             throw $exception;
         };
 
-        $this->onFulfilled = function (ResponseInterface $response) use ($onFulfilled, $newPromise) {
+        $this->onFulfilled = function(ResponseInterface $response) use ($onFulfilled, $newPromise) {
             try {
                 $return = $onFulfilled($response);
 
@@ -89,7 +89,7 @@ 
             }
         };
 
-        $this->onRejected = function (Exception $exception) use ($onRejected, $newPromise) {
+        $this->onRejected = function(Exception $exception) use ($onRejected, $newPromise) {
             try {
                 $newPromise->resolve($onRejected($exception));
             } catch (Exception $exception) {
@@ -177,7 +177,7 @@ 
     {
         $loop = $this->loop;
         while (HttpPromise::PENDING === $this->getState()) {
-            $loop->futureTick(function () use ($loop) {
+            $loop->futureTick(function() use ($loop) {
                 $loop->stop();
             });
             $loop->run();

src/Client.php

Spacing +4 added lines, -4 removed lines

@@ -94,7 +94,7 @@ 
         $reactRequest = $this->buildReactRequest($request);
         $promise = new Promise($this->loop);
 
-        $reactRequest->on('error', function (\Exception $error) use ($promise, $request) {
+        $reactRequest->on('error', function(\Exception $error) use ($promise, $request) {
             $promise->reject(new RequestException(
                 $error->getMessage(),
                 $request,
@@ -102,13 +102,13 @@ 
             ));
         });
 
-        $reactRequest->on('response', function (ReactResponse $reactResponse = null) use ($promise, $request) {
+        $reactRequest->on('response', function(ReactResponse $reactResponse = null) use ($promise, $request) {
             $bodyStream = $this->streamFactory->createStream();
-            $reactResponse->on('data', function ($data) use (&$bodyStream) {
+            $reactResponse->on('data', function($data) use (&$bodyStream) {
                 $bodyStream->write((string) $data);
             });
 
-            $reactResponse->on('end', function (\Exception $error = null) use ($promise, $request, $reactResponse, &$bodyStream) {
+            $reactResponse->on('end', function(\Exception $error = null) use ($promise, $request, $reactResponse, &$bodyStream) {
                 $response = $this->buildResponse(
                     $reactResponse,
                     $bodyStream