Skip to content

Commit a735d4b

Browse files
committed
Line length
1 parent 02ddfee commit a735d4b

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

src/AsyncClient.php

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,13 @@ public function __construct(
3737
Client $client = null
3838
) {
3939
if (!($client instanceof Client)) {
40-
$this->options = ApiSettings::getOptions($consumerKey, $consumerSecret, $accessToken, $accessTokenSecret, 'Async');
40+
$this->options = ApiSettings::getOptions(
41+
$consumerKey,
42+
$consumerSecret,
43+
$accessToken,
44+
$accessTokenSecret,
45+
'Async'
46+
);
4147
$client = Factory::create($loop, $this->options);
4248
}
4349
$this->client = $client;
@@ -87,7 +93,9 @@ protected function stream(RequestInterface $request): Observable
8793
return trim($json) !== ''; // To keep the stream alive Twitter sends an empty line at times
8894
})->jsonDecode()->flatMap(function (array $document) {
8995
if (isset($document['delete'])) {
90-
return Promise::toObservable($this->client->handle(new HydrateCommand('DeletedTweet', $document['delete'])));
96+
return Promise::toObservable($this->client->handle(
97+
new HydrateCommand('DeletedTweet', $document['delete'])
98+
));
9199
}
92100

93101
return Promise::toObservable($this->client->handle(new HydrateCommand('Tweet', $document)));

0 commit comments

Comments
 (0)