swooletw / laravel-swoole

src/Coroutine/PDO.php

Spacing +4 added lines, -4 removed lines

@@ -56,7 +56,7 @@ 
     {
         $this->client->connect($options);
 
-        if (! $this->client->connected) {
+        if (!$this->client->connected) {
             $message = $this->client->connect_error ?: $this->client->error;
             $errorCode = $this->client->connect_errno ?: $this->client->errno;
 
@@ -101,7 +101,7 @@ 
 
     public static function checkDriver(string $driver)
     {
-        if (! in_array($driver, static::getAvailableDrivers())) {
+        if (!in_array($driver, static::getAvailableDrivers())) {
             throw new \InvalidArgumentException("{$driver} driver is not supported yet.");
         }
     }
@@ -126,7 +126,7 @@ 
     public function commit()
     {
         $this->client->commit();
-        $this->inTransaction = false;//TODO I think it's sample to rollback, please confirm it
+        $this->inTransaction = false; //TODO I think it's sample to rollback, please confirm it
     }
 
     public function inTransaction()
@@ -185,7 +185,7 @@ 
             $bindKeyMap = [];
             $statement = preg_replace_callback(
                 '/:(\w+)\b/',
-                function ($matches) use (&$i, &$bindKeyMap) {
+                function($matches) use (&$i, &$bindKeyMap) {
                     $bindKeyMap[$matches[1]] = $i++;
 
                     return '?';

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));
             });
         });