swooletw / laravel-swoole

src/HttpServiceProvider.php

Spacing +8 added lines, -8 removed lines

@@ -130,7 +130,7 @@ 
         $options = $config->get('swoole_http.server.options');
 
         // only enable task worker in websocket mode and for queue driver
-        if ($config->get('queue.default') !== 'swoole' && ! $this->isWebsocket) {
+        if ($config->get('queue.default') !== 'swoole' && !$this->isWebsocket) {
             unset($config['task_worker_num']);
         }
 
@@ -144,7 +144,7 @@ 
      */
     protected function registerServer()
     {
-        $this->app->singleton(Server::class, function () {
+        $this->app->singleton(Server::class, function() {
             if (is_null(static::$server)) {
                 $this->createSwooleServer();
                 $this->configureSwooleServer();
@@ -163,15 +163,15 @@ 
      */
     protected function registerDatabaseDriver()
     {
-        $this->app->extend('db', function ($db) {
-            $db->extend('mysql-coroutine', function ($config, $name) {
+        $this->app->extend('db', function($db) {
+            $db->extend('mysql-coroutine', function($config, $name) {
                 $config['name'] = $name;
 
                 if (isset($config['read'])) {
                     $config = array_merge($config, $config['read']);
                 }
 
-                $connectionRead = function () use ($config) {
+                $connectionRead = function() use ($config) {
                     return (new MySqlConnector())->connect($config);
                 };
 
@@ -179,7 +179,7 @@ 
                     $config = array_merge($config, $config['write']);
                 }
 
-                $connection = function () use ($config) {
+                $connection = function() use ($config) {
                     return (new MySqlConnector())->connect($config);
                 };
 
@@ -200,8 +200,8 @@ 
      */
     protected function registerSwooleQueueDriver()
     {
-        $this->app->afterResolving('queue', function ($manager) {
-            $manager->addConnector('swoole', function () {
+        $this->app->afterResolving('queue', function($manager) {
+            $manager->addConnector('swoole', function() {
                 return new SwooleTaskConnector($this->app->make(Server::class));
             });
         });