sagebind / slack-client

src/RealTimeClient.php

Spacing +8 added lines, -8 removed lines

@@ -97,7 +97,7 @@ 
         $this->apiCall('rtm.start')
 
         // then connect to the socket...
-        ->then(function (Payload $response) {
+        ->then(function(Payload $response) {
             $responseData = $response->getData();
             // get the team info
             $this->team = new Team($this, $responseData['team']);
@@ -130,20 +130,20 @@ 
         }, function($exception) use ($deferred) {
             // if connection was not successful
             $deferred->reject(new ConnectionException(
-                'Could not connect to Slack API: '. $exception->getMessage(),
+                'Could not connect to Slack API: '.$exception->getMessage(),
                 $exception->getCode()
             ));
         })
 
         // then wait for the connection to be ready.
-        ->then(function (WebSocket $socket) use ($deferred) {
+        ->then(function(WebSocket $socket) use ($deferred) {
             $this->websocket = $socket;
 
-            $this->once('hello', function () use ($deferred) {
+            $this->once('hello', function() use ($deferred) {
                 $deferred->resolve();
             });
 
-            $this->once('error', function ($data) use ($deferred) {
+            $this->once('error', function($data) use ($deferred) {
                 $deferred->reject(new ConnectionException(
                     'Could not connect to WebSocket: '.$data['error']['msg'],
                     $data['error']['code']));
@@ -293,8 +293,8 @@ 
      */
     private function newWebSocket($url)
     {
-        return $this->wsFactory->__invoke($url)->then(function (WebSocket $socket) {
-            $socket->on('message', function ($data) {
+        return $this->wsFactory->__invoke($url)->then(function(WebSocket $socket) {
+            $socket->on('message', function($data) {
                 // parse the message and get the event name
                 $this->onMessage(Payload::fromJson($data));
             });
@@ -326,7 +326,7 @@ 
                     break;
 
                 case 'channel_created':
-                    $this->getChannelById($payload['channel']['id'])->then(function (Channel $channel) {
+                    $this->getChannelById($payload['channel']['id'])->then(function(Channel $channel) {
                         $this->channels[$channel->getId()] = $channel;
                     });
                     break;