@@ -192,7 +192,7 @@ discard block |
||
| 192 | 192 | ) || $config->get('queue.default') === 'swoole'; |
| 193 | 193 | |
| 194 | 194 | // only enable task worker in websocket mode and for queue driver |
| 195 | - if (! $isDefinedSwooleDriver && ! $this->isWebsocket) { |
|
| 195 | + if (!$isDefinedSwooleDriver && !$this->isWebsocket) { |
|
| 196 | 196 | unset($options['task_worker_num']); |
| 197 | 197 | } |
| 198 | 198 | |
@@ -206,7 +206,7 @@ discard block |
||
| 206 | 206 | */ |
| 207 | 207 | protected function registerServer() |
| 208 | 208 | { |
| 209 | - $this->app->singleton(Server::class, function () { |
|
| 209 | + $this->app->singleton(Server::class, function() { |
|
| 210 | 210 | if (is_null(static::$server)) { |
| 211 | 211 | $this->createSwooleServer(); |
| 212 | 212 | $this->configureSwooleServer(); |
@@ -222,8 +222,8 @@ discard block |
||
| 222 | 222 | */ |
| 223 | 223 | protected function registerDatabaseDriver() |
| 224 | 224 | { |
| 225 | - $this->app->extend(DatabaseManager::class, function (DatabaseManager $db) { |
|
| 226 | - $db->extend('mysql-coroutine', function ($config, $name) { |
|
| 225 | + $this->app->extend(DatabaseManager::class, function(DatabaseManager $db) { |
|
| 226 | + $db->extend('mysql-coroutine', function($config, $name) { |
|
| 227 | 227 | $config['name'] = $name; |
| 228 | 228 | |
| 229 | 229 | $connection = new MySqlConnection( |
@@ -266,8 +266,8 @@ discard block |
||
| 266 | 266 | */ |
| 267 | 267 | protected function registerSwooleQueueDriver() |
| 268 | 268 | { |
| 269 | - $this->app->afterResolving('queue', function (QueueManager $manager) { |
|
| 270 | - $manager->addConnector('swoole', function () { |
|
| 269 | + $this->app->afterResolving('queue', function(QueueManager $manager) { |
|
| 270 | + $manager->addConnector('swoole', function() { |
|
| 271 | 271 | return new SwooleTaskConnector($this->app->make(Server::class)); |
| 272 | 272 | }); |
| 273 | 273 | }); |