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