hhxsv5 / laravel-s

src/Swoole/Server.php

Spacing +16 added lines, -16 removed lines

@@ -41,7 +41,7 @@ 
 
         $ip = isset($conf['listen_ip']) ? $conf['listen_ip'] : '127.0.0.1';
         $port = isset($conf['listen_port']) ? $conf['listen_port'] : 5200;
-        $socketType = isset($conf['socket_type']) ? (int)$conf['socket_type'] : SWOOLE_SOCK_TCP;
+        $socketType = isset($conf['socket_type']) ? (int) $conf['socket_type'] : SWOOLE_SOCK_TCP;
 
         if ($socketType === SWOOLE_SOCK_UNIX_STREAM) {
             $socketDir = dirname($ip);
@@ -97,7 +97,7 @@ 
 
     protected function triggerWebSocketEvent($event, array $params)
     {
-        return $this->callWithCatchException(function () use ($event, $params) {
+        return $this->callWithCatchException(function() use ($event, $params) {
             $handler = $this->getWebSocketHandler();
 
             if (method_exists($handler, $event)) {
@@ -116,19 +116,19 @@ 
     protected function bindWebSocketEvents()
     {
         if ($this->enableWebSocket) {
-            $this->swoole->on('HandShake', function () {
+            $this->swoole->on('HandShake', function() {
                 return $this->triggerWebSocketEvent('onHandShake', func_get_args());
             });
 
-            $this->swoole->on('Open', function () {
+            $this->swoole->on('Open', function() {
                 $this->triggerWebSocketEvent('onOpen', func_get_args());
             });
 
-            $this->swoole->on('Message', function () {
+            $this->swoole->on('Message', function() {
                 $this->triggerWebSocketEvent('onMessage', func_get_args());
             });
 
-            $this->swoole->on('Close', function (WebSocketServer $server, $fd, $reactorId) {
+            $this->swoole->on('Close', function(WebSocketServer $server, $fd, $reactorId) {
                 $clientInfo = $server->getClientInfo($fd);
                 if (isset($clientInfo['websocket_status']) && $clientInfo['websocket_status'] === \WEBSOCKET_STATUS_FRAME) {
                     $this->triggerWebSocketEvent('onClose', func_get_args());
@@ -156,10 +156,10 @@ 
             $port->set(empty($socket['settings']) ? [] : $socket['settings']);
 
             $handlerClass = $socket['handler'];
-            $eventHandler = function ($method, array $params) use ($port, $handlerClass) {
+            $eventHandler = function($method, array $params) use ($port, $handlerClass) {
                 $handler = $this->getSocketHandler($port, $handlerClass);
                 if (method_exists($handler, $method)) {
-                    $this->callWithCatchException(function () use ($handler, $method, $params) {
+                    $this->callWithCatchException(function() use ($handler, $method, $params) {
                         call_user_func_array([$handler, $method], $params);
                     });
                 }
@@ -177,8 +177,8 @@ 
                 'BufferEmpty',
             ];
             foreach ($events as $event) {
-                $port->on($event, function () use ($event, $eventHandler) {
-                    return $eventHandler('on' . $event, func_get_args());
+                $port->on($event, function() use ($event, $eventHandler) {
+                    return $eventHandler('on'.$event, func_get_args());
                 });
             }
         }
@@ -217,7 +217,7 @@ 
 
     protected function bindSwooleTables()
     {
-        $tables = isset($this->conf['swoole_tables']) ? (array)$this->conf['swoole_tables'] : [];
+        $tables = isset($this->conf['swoole_tables']) ? (array) $this->conf['swoole_tables'] : [];
         foreach ($tables as $name => $table) {
             $t = new Table($table['size']);
             foreach ($table['column'] as $column) {
@@ -314,7 +314,7 @@ 
         $headers = [
             'Upgrade'               => 'websocket',
             'Connection'            => 'Upgrade',
-            'Sec-WebSocket-Accept'  => base64_encode(sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
+            'Sec-WebSocket-Accept'  => base64_encode(sha1($secKey.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
             'Sec-WebSocket-Version' => '13',
         ];
 
@@ -361,7 +361,7 @@ 
             if (!($listener instanceof Listener)) {
                 throw new \InvalidArgumentException(sprintf('%s must extend the abstract class %s', $listenerClass, Listener::class));
             }
-            $this->callWithCatchException(function () use ($listener) {
+            $this->callWithCatchException(function() use ($listener) {
                 $listener->handle();
             }, [], $event->getTries());
         }
@@ -370,7 +370,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -379,7 +379,7 @@ 
     protected function fireEvent($event, $interface, array $arguments)
     {
         if (isset($this->conf['event_handlers'][$event])) {
-            $eventHandlers = (array)$this->conf['event_handlers'][$event];
+            $eventHandlers = (array) $this->conf['event_handlers'][$event];
             foreach ($eventHandlers as $eventHandler) {
                 if (!isset(class_implements($eventHandler)[$interface])) {
                     throw new \InvalidArgumentException(sprintf(
@@ -389,7 +389,7 @@ 
                         )
                     );
                 }
-                $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+                $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                     call_user_func_array([(new $eventHandler), 'handle'], $arguments);
                 });
             }