@@ -58,12 +58,12 @@ discard block |
||
| 58 | 58 | $deferred = new Deferred(); |
| 59 | 59 | |
| 60 | 60 | $receivedData = ''; |
| 61 | - $request->on('response', function (Response $response) use ($deferred, &$receivedData) { |
|
| 62 | - $response->on('data', function ($chunk) use (&$receivedData) { |
|
| 61 | + $request->on('response', function(Response $response) use ($deferred, &$receivedData) { |
|
| 62 | + $response->on('data', function($chunk) use (&$receivedData) { |
|
| 63 | 63 | $receivedData .= $chunk; |
| 64 | 64 | }); |
| 65 | 65 | |
| 66 | - $response->on('end', function () use (&$receivedData, $deferred, $response) { |
|
| 66 | + $response->on('end', function() use (&$receivedData, $deferred, $response) { |
|
| 67 | 67 | try { |
| 68 | 68 | $endResponse = new Response($receivedData, $response->getHeaders()); |
| 69 | 69 | $deferred->resolve($endResponse); |
@@ -73,7 +73,7 @@ discard block |
||
| 73 | 73 | }); |
| 74 | 74 | }); |
| 75 | 75 | |
| 76 | - $request->on('error', function (\Exception $e) use ($deferred) { |
|
| 76 | + $request->on('error', function(\Exception $e) use ($deferred) { |
|
| 77 | 77 | $deferred->reject(new ClientException($e->getMessage(), $e->getCode(), $e)); |
| 78 | 78 | }); |
| 79 | 79 | |
@@ -96,9 +96,9 @@ discard block |
||
| 96 | 96 | $option = $this->bodyConstructor->constructOptions($method); |
| 97 | 97 | |
| 98 | 98 | return $this->sendRequestToTelegram($method, $option) |
| 99 | - ->then(function (Response $response) use ($method) { |
|
| 99 | + ->then(function(Response $response) use ($method) { |
|
| 100 | 100 | return $method::bindToObject($response, $this->logger); |
| 101 | - }, function ($error) { |
|
| 101 | + }, function($error) { |
|
| 102 | 102 | $this->logger->error($error); |
| 103 | 103 | throw $error; |
| 104 | 104 | }); |
@@ -158,7 +158,7 @@ discard block |
||
| 158 | 158 | $this->logger->debug('About to perform request to begin downloading file'); |
| 159 | 159 | |
| 160 | 160 | return $this->requestHandler->get($url)->then( |
| 161 | - function (TelegramResponse $rawData) { |
|
| 161 | + function(TelegramResponse $rawData) { |
|
| 162 | 162 | return new TelegramDocument($rawData); |
| 163 | 163 | } |
| 164 | 164 | ); |
@@ -14,7 +14,7 @@ discard block |
||
| 14 | 14 | { |
| 15 | 15 | $deferred = new Deferred(); |
| 16 | 16 | |
| 17 | - $promise->onResolve(function ($error = null, $result = null) use ($deferred) { |
|
| 17 | + $promise->onResolve(function($error = null, $result = null) use ($deferred) { |
|
| 18 | 18 | $error ? $deferred->reject($error) : $deferred->resolve($result); |
| 19 | 19 | }); |
| 20 | 20 | |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | */ |
| 78 | 78 | public function processRequest(Request $request) |
| 79 | 79 | { |
| 80 | - return reactAdapt(\Amp\call(function () use ($request) { |
|
| 80 | + return reactAdapt(\Amp\call(function() use ($request) { |
|
| 81 | 81 | /** @var Response $response */ |
| 82 | 82 | $response = yield $this->client->request($request); |
| 83 | 83 | |