|
7 | 7 | use React\HttpClient\Client;
|
8 | 8 | use React\HttpClient\Request as ReactRequest;
|
9 | 9 | use React\HttpClient\Response as ReactResponse;
|
10 |
| - |
11 | 10 | use Http\Client\HttpClient;
|
12 | 11 | use Http\Client\HttpAsyncClient;
|
13 | 12 | use Http\Client\Promise;
|
14 | 13 | use Http\Client\Exception\HttpException;
|
15 | 14 | use Http\Client\Exception\RequestException;
|
16 | 15 | use Http\Message\MessageFactory;
|
17 |
| - |
18 | 16 | use Psr\Http\Message\RequestInterface;
|
19 | 17 | use Psr\Http\Message\StreamInterface;
|
20 | 18 |
|
@@ -47,9 +45,9 @@ public function __construct(
|
47 | 45 | Client $client = null
|
48 | 46 | ) {
|
49 | 47 | $this->loop = null === $loop?ReactFactory::buildEventLoop():$loop;
|
50 |
| - if( null === $client ) { |
| 48 | + if (null === $client) { |
51 | 49 | $this->client = ReactFactory::buildHttpClient($this->loop);
|
52 |
| - } elseif( null === $loop ) { |
| 50 | + } elseif (null === $loop) { |
53 | 51 | throw new \RuntimeException(
|
54 | 52 | "You must give a LoopInterface instance with the Client"
|
55 | 53 | );
|
@@ -81,30 +79,30 @@ public function sendAsyncRequest(RequestInterface $request)
|
81 | 79 | $requestStream = $this->buildReactRequest($request);
|
82 | 80 | $deferred = new Deferred();
|
83 | 81 |
|
84 |
| - $requestStream->on('error', function(\Exception $error) use ($deferred, $request) { |
| 82 | + $requestStream->on('error', function (\Exception $error) use ($deferred, $request) { |
85 | 83 | $deferred->reject(new RequestException(
|
86 | 84 | $error->getMessage(),
|
87 | 85 | $request,
|
88 | 86 | $error
|
89 | 87 | ));
|
90 | 88 | });
|
91 |
| - $requestStream->on('response', function(ReactResponse $response = null) use ($deferred, $requestStream, $request) { |
| 89 | + $requestStream->on('response', function (ReactResponse $response = null) use ($deferred, $requestStream, $request) { |
92 | 90 | $bodyStream = null;
|
93 |
| - $response->on('data', function($data) use (&$bodyStream) { |
94 |
| - if( $data instanceof StreamInterface ) { |
| 91 | + $response->on('data', function ($data) use (&$bodyStream) { |
| 92 | + if ($data instanceof StreamInterface) { |
95 | 93 | $bodyStream = $data;
|
96 | 94 | } else {
|
97 | 95 | $bodyStream->write($data);
|
98 | 96 | }
|
99 | 97 | });
|
100 | 98 |
|
101 |
| - $response->on('end', function(\Exception $error = null) use ($deferred, $request, $response, &$bodyStream) { |
| 99 | + $response->on('end', function (\Exception $error = null) use ($deferred, $request, $response, &$bodyStream) { |
102 | 100 | $bodyStream->rewind();
|
103 | 101 | $psr7Response = $this->messageFactory->buildResponse(
|
104 | 102 | $response,
|
105 | 103 | $bodyStream
|
106 | 104 | );
|
107 |
| - if( null !== $error ) { |
| 105 | + if (null !== $error) { |
108 | 106 | $deferred->reject(new HttpException(
|
109 | 107 | $error->getMessage(),
|
110 | 108 | $request,
|
@@ -132,10 +130,10 @@ public function sendAsyncRequest(RequestInterface $request)
|
132 | 130 | private function buildReactRequest(RequestInterface $request)
|
133 | 131 | {
|
134 | 132 | $headers = [];
|
135 |
| - foreach( $request->getHeaders() as $name => $value ) { |
| 133 | + foreach ($request->getHeaders() as $name => $value) { |
136 | 134 | $headers[$name] = (is_array($value)?$value[0]:$value);
|
137 | 135 | }
|
138 |
| - if( $request->getBody()->getSize() > 0 ) { |
| 136 | + if ($request->getBody()->getSize() > 0) { |
139 | 137 | $headers['Content-Length'] = $request->getBody()->getSize();
|
140 | 138 | }
|
141 | 139 |
|
|
0 commit comments