@@ -22,7 +22,7 @@ discard block |
||
| 22 | 22 | |
| 23 | 23 | $rootNode |
| 24 | 24 | ->validate() |
| 25 | - ->always(function ($v) { |
|
| 25 | + ->always(function($v) { |
|
| 26 | 26 | foreach ($v['operations'] as $name => $operation) { |
| 27 | 27 | if (!$operation['requestProtocol']) { |
| 28 | 28 | $v['operations'][$name]['requestProtocol'] = $v['protocol']; |
@@ -121,7 +121,7 @@ discard block |
||
| 121 | 121 | ->isRequired() |
| 122 | 122 | ->beforeNormalization() |
| 123 | 123 | ->ifString() |
| 124 | - ->then(function ($v) { |
|
| 124 | + ->then(function($v) { |
|
| 125 | 125 | return strtoupper($v); |
| 126 | 126 | }) |
| 127 | 127 | ->end() |
@@ -135,7 +135,7 @@ discard block |
||
| 135 | 135 | ->cannotBeEmpty() |
| 136 | 136 | ->validate() |
| 137 | 137 | ->ifString() |
| 138 | - ->then(function ($v) { |
|
| 138 | + ->then(function($v) { |
|
| 139 | 139 | return '/'.ltrim($v, '/'); |
| 140 | 140 | }) |
| 141 | 141 | ->end() |
@@ -224,7 +224,7 @@ discard block |
||
| 224 | 224 | |
| 225 | 225 | $rootNode |
| 226 | 226 | ->beforeNormalization() |
| 227 | - ->always(function ($v) use ($fromOperation) { |
|
| 227 | + ->always(function($v) use ($fromOperation) { |
|
| 228 | 228 | if (!$fromOperation) { |
| 229 | 229 | if (isset($v['shape'])) { |
| 230 | 230 | throw new InvalidSpecificationException('Unrecognized option "shape"'); |
@@ -258,7 +258,7 @@ discard block |
||
| 258 | 258 | ->arrayNode('members') |
| 259 | 259 | ->beforeNormalization() |
| 260 | 260 | ->ifArray() |
| 261 | - ->then(function ($v) { |
|
| 261 | + ->then(function($v) { |
|
| 262 | 262 | foreach ($v as $name => $member) { |
| 263 | 263 | if (!isset($member['locationName'])) { |
| 264 | 264 | $v[$name]['locationName'] = $name; |
@@ -338,7 +338,7 @@ discard block |
||
| 338 | 338 | { |
| 339 | 339 | $rootNode |
| 340 | 340 | ->beforeNormalization() |
| 341 | - ->always(function ($v) use ($fromOperation) { |
|
| 341 | + ->always(function($v) use ($fromOperation) { |
|
| 342 | 342 | if (!$fromOperation) { |
| 343 | 343 | if (isset($v['errorShape'])) { |
| 344 | 344 | throw new InvalidSpecificationException('Unrecognized option "errorShape"'); |
@@ -117,13 +117,13 @@ discard block |
||
| 117 | 117 | { |
| 118 | 118 | // Modify provided callbacks to track results. |
| 119 | 119 | $results = []; |
| 120 | - $options['fulfilled'] = function ($v, $k) use (&$results, $options) { |
|
| 120 | + $options['fulfilled'] = function($v, $k) use (&$results, $options) { |
|
| 121 | 121 | if (isset($options['fulfilled'])) { |
| 122 | 122 | $options['fulfilled']($v, $k); |
| 123 | 123 | } |
| 124 | 124 | $results[$k] = $v; |
| 125 | 125 | }; |
| 126 | - $options['rejected'] = function ($v, $k) use (&$results, $options) { |
|
| 126 | + $options['rejected'] = function($v, $k) use (&$results, $options) { |
|
| 127 | 127 | if (isset($options['rejected'])) { |
| 128 | 128 | $options['rejected']($v, $k); |
| 129 | 129 | } |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | |
| 133 | 133 | // Execute multiple commands synchronously, then sort and return the results. |
| 134 | 134 | return $this->executeAllAsync($commands, $options) |
| 135 | - ->then(function () use (&$results) { |
|
| 135 | + ->then(function() use (&$results) { |
|
| 136 | 136 | ksort($results); |
| 137 | 137 | |
| 138 | 138 | return $results; |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | |
| 153 | 153 | // Convert the iterator of commands to a generator of promises. |
| 154 | 154 | $commands = Promise\iter_for($commands); |
| 155 | - $promises = function () use ($commands) { |
|
| 155 | + $promises = function() use ($commands) { |
|
| 156 | 156 | foreach ($commands as $key => $command) { |
| 157 | 157 | if (!$command instanceof CommandInterface) { |
| 158 | 158 | throw new \InvalidArgumentException('The iterator must ' |
@@ -195,8 +195,8 @@ discard block |
||
| 195 | 195 | */ |
| 196 | 196 | private function createCommandHandler() |
| 197 | 197 | { |
| 198 | - return function (CommandInterface $command) { |
|
| 199 | - return Promise\coroutine(function () use ($command) { |
|
| 198 | + return function(CommandInterface $command) { |
|
| 199 | + return Promise\coroutine(function() use ($command) { |
|
| 200 | 200 | // Prepare the HTTP options. |
| 201 | 201 | $opts = $command['@http'] ?: []; |
| 202 | 202 | |
@@ -35,7 +35,7 @@ discard block |
||
| 35 | 35 | */ |
| 36 | 36 | public function commandToRequestTransformer() |
| 37 | 37 | { |
| 38 | - return function (CommandInterface $command) { |
|
| 38 | + return function(CommandInterface $command) { |
|
| 39 | 39 | if (!$this->service->hasOperation($command->getName())) { |
| 40 | 40 | throw new CommandException(sprintf( |
| 41 | 41 | 'Command "%s" not found', |
@@ -89,7 +89,7 @@ discard block |
||
| 89 | 89 | */ |
| 90 | 90 | public function responseToResultTransformer() |
| 91 | 91 | { |
| 92 | - return function ( |
|
| 92 | + return function( |
|
| 93 | 93 | ResponseInterface $response, |
| 94 | 94 | RequestInterface $request, |
| 95 | 95 | CommandInterface $command |
@@ -114,7 +114,7 @@ discard block |
||
| 114 | 114 | |
| 115 | 115 | public function badResponseExceptionParser() |
| 116 | 116 | { |
| 117 | - return function (CommandInterface $command, GuzzleBadResponseException $e) { |
|
| 117 | + return function(CommandInterface $command, GuzzleBadResponseException $e) { |
|
| 118 | 118 | $operation = $this->service->getOperation($command->getName()); |
| 119 | 119 | |
| 120 | 120 | return $this->processResponseError( |