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);
@@ -98,28 +98,28 @@ 
     protected function bindWebSocketEvent()
     {
         if ($this->enableWebSocket) {
-            $eventHandler = function ($method, array $params) {
-                $this->callWithCatchException(function () use ($method, $params) {
+            $eventHandler = function($method, array $params) {
+                $this->callWithCatchException(function() use ($method, $params) {
                     call_user_func_array([$this->getWebSocketHandler(), $method], $params);
                 });
             };
 
             $handler = $this->getWebSocketHandler();
             if (method_exists($handler, 'onHandShake')) {
-                $this->swoole->on('HandShake', function () use ($eventHandler) {
+                $this->swoole->on('HandShake', function() use ($eventHandler) {
                     $eventHandler('onHandShake', func_get_args());
                 });
             }
 
-            $this->swoole->on('Open', function () use ($eventHandler) {
+            $this->swoole->on('Open', function() use ($eventHandler) {
                 $eventHandler('onOpen', func_get_args());
             });
 
-            $this->swoole->on('Message', function () use ($eventHandler) {
+            $this->swoole->on('Message', function() use ($eventHandler) {
                 $eventHandler('onMessage', func_get_args());
             });
 
-            $this->swoole->on('Close', function (WebSocketServer $server, $fd, $reactorId) use ($eventHandler) {
+            $this->swoole->on('Close', function(WebSocketServer $server, $fd, $reactorId) use ($eventHandler) {
                 $clientInfo = $server->getClientInfo($fd);
                 if (isset($clientInfo['websocket_status']) && $clientInfo['websocket_status'] === \WEBSOCKET_STATUS_FRAME) {
                     $eventHandler('onClose', func_get_args());
@@ -147,10 +147,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);
                     });
                 }
@@ -168,8 +168,8 @@ 
                 'BufferEmpty',
             ];
             foreach ($events as $event) {
-                $port->on($event, function () use ($event, $eventHandler) {
-                    $eventHandler('on' . $event, func_get_args());
+                $port->on($event, function() use ($event, $eventHandler) {
+                    $eventHandler('on'.$event, func_get_args());
                 });
             }
         }
@@ -208,7 +208,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) {
@@ -315,7 +315,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());
         }
@@ -324,7 +324,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -333,7 +333,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(
@@ -343,7 +343,7 @@ 
                         )
                     );
                 }
-                $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+                $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                     call_user_func_array([(new $eventHandler), 'handle'], $arguments);
                 });
             }