RushCode / m1-api

src/HttpClientRequestHandler.php

Spacing +4 added lines, -4 removed lines

@@ -58,12 +58,12 @@ 
         $deferred = new Deferred();
 
         $receivedData = '';
-        $request->on('response', function (Response $response) use ($deferred, &$receivedData) {
-            $response->on('data', function ($chunk) use (&$receivedData) {
+        $request->on('response', function(Response $response) use ($deferred, &$receivedData) {
+            $response->on('data', function($chunk) use (&$receivedData) {
                 $receivedData .= $chunk;
             });
 
-            $response->on('end', function () use (&$receivedData, $deferred, $response) {
+            $response->on('end', function() use (&$receivedData, $deferred, $response) {
                 try {
                     $endResponse = new Response($receivedData, $response->getHeaders());
                     $deferred->resolve($endResponse);
@@ -73,7 +73,7 @@ 
             });
         });
 
-        $request->on('error', function (\Exception $e) use ($deferred) {
+        $request->on('error', function(\Exception $e) use ($deferred) {
             $deferred->reject(new ClientException($e->getMessage(), $e->getCode(), $e));
         });
 

src/HttpClientRequestHandlerAmp.php

Spacing +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
 {
     $deferred = new Deferred();
 
-    $promise->onResolve(function ($error = null, $result = null) use ($deferred) {
+    $promise->onResolve(function($error = null, $result = null) use ($deferred) {
         $error ? $deferred->reject($error) : $deferred->resolve($result);
     });
 
@@ -77,7 +77,7 @@ 
      */
     public function processRequest(Request $request)
     {
-        return reactAdapt(\Amp\call(function () use ($request) {
+        return reactAdapt(\Amp\call(function() use ($request) {
             /** @var Response $response */
             $response = yield $this->client->request($request);
 

src/Api.php

Spacing +2 added lines, -2 removed lines

@@ -79,9 +79,9 @@
         $option = $this->bodyConstructor->constructOptions($method);
 
         return $this->sendRequestToTelegram($method, $option)
-            ->then(function (Response $response) use ($method) {
+            ->then(function(Response $response) use ($method) {
                 return $method::bindToObject($response, $this->logger);
-            }, function ($error) {
+            }, function($error) {
                 $this->logger->error($error);
                 throw $error;
             });