Skip to content

Commit 773d8b8

Browse files
committed
Fixed line lengths
1 parent b09a3a2 commit 773d8b8

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/AsyncClient.php

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,9 @@ public function __construct(Observable $client)
102102
$event = Event::createFromMessage($message);
103103

104104
if ($event->getEvent() === 'pusher:error') {
105-
return Observable::fromPromise(reject(new PusherErrorException($event->getData()['message'], $event->getData()['code'])));
105+
return Observable::fromPromise(reject(
106+
new PusherErrorException($event->getData()['message'], $event->getData()['code'])
107+
));
106108
}
107109

108110
if ($event->getEvent() === 'pusher:connection_established') {
@@ -221,7 +223,11 @@ public function send(array $message): bool
221223
*/
222224
private function handleLowLevelError(Throwable $throwable)
223225
{
224-
if (!($throwable instanceof WebsocketErrorException) && !($throwable instanceof RuntimeException) && !($throwable instanceof PusherErrorException)) {
226+
if (
227+
!($throwable instanceof WebsocketErrorException) &&
228+
!($throwable instanceof RuntimeException) &&
229+
!($throwable instanceof PusherErrorException)
230+
) {
225231
return Observable::fromPromise(reject($throwable));
226232
}
227233

0 commit comments

Comments
 (0)