@@ -17,7 +17,6 @@ |
||
17 | 17 | use Monolog\Logger; |
18 | 18 | use Psr\Http\Message\ResponseInterface; |
19 | 19 | use React\EventLoop\ExtEventLoop; |
20 | -use React\EventLoop\Factory as EventLoop; |
|
21 | 20 | use React\EventLoop\LibEventLoop; |
22 | 21 | use React\EventLoop\LibEvLoop; |
23 | 22 | use React\EventLoop\LoopInterface; |
@@ -88,7 +88,7 @@ discard block |
||
88 | 88 | { |
89 | 89 | $observer = new Observer(); |
90 | 90 | |
91 | - $this->promise($route)->then(function (ResponseInterface $response) use ($observer) { |
|
91 | + $this->promise($route)->then(function(ResponseInterface $response) use ($observer) { |
|
92 | 92 | $this->onConnect($response, $observer); |
93 | 93 | }); |
94 | 94 | |
@@ -105,7 +105,7 @@ discard block |
||
105 | 105 | list($method, $uri) = [$route->method(), $route->build()]; |
106 | 106 | |
107 | 107 | // Log request |
108 | - $this->client->log(' -> ' . $method . ' ' . $uri, Logger::DEBUG); |
|
108 | + $this->client->log(' -> '.$method.' '.$uri, Logger::DEBUG); |
|
109 | 109 | |
110 | 110 | return $this->browser |
111 | 111 | ->withOptions(['streaming' => true]) |
@@ -121,16 +121,16 @@ discard block |
||
121 | 121 | $json = new JsonStream(); |
122 | 122 | |
123 | 123 | // Log response |
124 | - $this->client->log(' <- ' . $response->getStatusCode() . ' ' . $response->getReasonPhrase(), Logger::DEBUG); |
|
124 | + $this->client->log(' <- '.$response->getStatusCode().' '.$response->getReasonPhrase(), Logger::DEBUG); |
|
125 | 125 | |
126 | 126 | /* @var $body ReadableStreamInterface */ |
127 | 127 | $body = $response->getBody(); |
128 | 128 | |
129 | - $body->on('data', function ($chunk) use ($json, $observer) { |
|
129 | + $body->on('data', function($chunk) use ($json, $observer) { |
|
130 | 130 | // Log response chunk |
131 | - $this->client->log(' <- ' . $chunk, Logger::DEBUG); |
|
131 | + $this->client->log(' <- '.$chunk, Logger::DEBUG); |
|
132 | 132 | |
133 | - $json->push($chunk, function ($object) use ($observer) { |
|
133 | + $json->push($chunk, function($object) use ($observer) { |
|
134 | 134 | $observer->fire($object); |
135 | 135 | }); |
136 | 136 | }); |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -1,4 +1,4 @@ discard block |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -210,7 +210,7 @@ discard block |
||
210 | 210 | $route = $updatedRoute; |
211 | 211 | } |
212 | 212 | |
213 | - return $this->url . $route . '?' . http_build_query($query); |
|
213 | + return $this->url.$route.'?'.http_build_query($query); |
|
214 | 214 | } |
215 | 215 | |
216 | 216 | /** |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |
@@ -1,4 +1,4 @@ |
||
1 | -<?php declare(strict_types=1); |
|
1 | +<?php declare(strict_types = 1); |
|
2 | 2 | /** |
3 | 3 | * This file is part of GitterApi package. |
4 | 4 | * |