@@ -143,7 +143,7 @@ |
||
143 | 143 | protected function setIlluminateResponse($illuminateResponse) |
144 | 144 | { |
145 | 145 | if (!$illuminateResponse instanceof SymfonyResponse) { |
146 | - $content = (string)$illuminateResponse; |
|
146 | + $content = (string) $illuminateResponse; |
|
147 | 147 | $illuminateResponse = new IlluminateResponse($content); |
148 | 148 | } |
149 | 149 |
@@ -56,7 +56,7 @@ |
||
56 | 56 | */ |
57 | 57 | public function disableFor($name) |
58 | 58 | { |
59 | - $this->except = array_merge($this->except, (array)$name); |
|
59 | + $this->except = array_merge($this->except, (array) $name); |
|
60 | 60 | } |
61 | 61 | |
62 | 62 | /** |
@@ -60,7 +60,7 @@ discard block |
||
60 | 60 | */ |
61 | 61 | protected function startSession(Request $request) |
62 | 62 | { |
63 | - return tap($this->getSession($request), function (Session $session) use ($request) { |
|
63 | + return tap($this->getSession($request), function(Session $session) use ($request) { |
|
64 | 64 | $session->setRequestOnHandler($request); |
65 | 65 | |
66 | 66 | $session->start(); |
@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | */ |
77 | 77 | public function getSession(Request $request) |
78 | 78 | { |
79 | - return tap($this->manager->driver(), function (Session $session) use ($request) { |
|
79 | + return tap($this->manager->driver(), function(Session $session) use ($request) { |
|
80 | 80 | $session->setId($request->cookies->get($session->getName())); |
81 | 81 | }); |
82 | 82 | } |
@@ -140,7 +140,7 @@ discard block |
||
140 | 140 | $this->checkTable($table); |
141 | 141 | $redisKey = $this->getKey($key, $table); |
142 | 142 | |
143 | - $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) { |
|
143 | + $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) { |
|
144 | 144 | foreach ($values as $value) { |
145 | 145 | $pipe->sadd($redisKey, $value); |
146 | 146 | } |
@@ -163,7 +163,7 @@ discard block |
||
163 | 163 | $this->checkTable($table); |
164 | 164 | $redisKey = $this->getKey($key, $table); |
165 | 165 | |
166 | - $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) { |
|
166 | + $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) { |
|
167 | 167 | foreach ($values as $value) { |
168 | 168 | $pipe->srem($redisKey, $value); |
169 | 169 | } |
@@ -119,7 +119,7 @@ |
||
119 | 119 | return null; |
120 | 120 | } |
121 | 121 | |
122 | - return (int)$type; |
|
122 | + return (int) $type; |
|
123 | 123 | } |
124 | 124 | |
125 | 125 | /** |
@@ -310,7 +310,7 @@ discard block |
||
310 | 310 | */ |
311 | 311 | protected function getFds() |
312 | 312 | { |
313 | - $fds = array_filter($this->to, function ($value) { |
|
313 | + $fds = array_filter($this->to, function($value) { |
|
314 | 314 | return is_integer($value); |
315 | 315 | }); |
316 | 316 | $rooms = array_diff($this->to, $fds); |
@@ -387,7 +387,7 @@ discard block |
||
387 | 387 | { |
388 | 388 | $pipeline = $this->pipeline; |
389 | 389 | |
390 | - $closure = function () use ($container) { |
|
390 | + $closure = function() use ($container) { |
|
391 | 391 | $this->container = $container; |
392 | 392 | }; |
393 | 393 | |
@@ -429,7 +429,7 @@ discard block |
||
429 | 429 | return $this->pipeline |
430 | 430 | ->send($request) |
431 | 431 | ->through($this->middleware) |
432 | - ->then(function ($request) { |
|
432 | + ->then(function($request) { |
|
433 | 433 | return $request; |
434 | 434 | }); |
435 | 435 | } |
@@ -64,7 +64,7 @@ |
||
64 | 64 | { |
65 | 65 | $users = is_object($users) ? func_get_args() : $users; |
66 | 66 | |
67 | - $userIds = array_map(function (AuthenticatableContract $user) { |
|
67 | + $userIds = array_map(function(AuthenticatableContract $user) { |
|
68 | 68 | $this->checkUser($user); |
69 | 69 | |
70 | 70 | return $user->getAuthIdentifier(); |
@@ -166,7 +166,7 @@ discard block |
||
166 | 166 | |
167 | 167 | // push message to designated fds |
168 | 168 | foreach ($push->getDescriptors() as $descriptor) { |
169 | - if ($server->exist($descriptor) || !$push->isBroadcastToDescriptor((int)$descriptor)) { |
|
169 | + if ($server->exist($descriptor) || !$push->isBroadcastToDescriptor((int) $descriptor)) { |
|
170 | 170 | $server->push($descriptor, $payload, $push->getOpcode()); |
171 | 171 | } |
172 | 172 | } |
@@ -232,7 +232,7 @@ discard block |
||
232 | 232 | */ |
233 | 233 | protected function filterWebsocket(array $descriptors): array |
234 | 234 | { |
235 | - $callback = function ($descriptor) { |
|
235 | + $callback = function($descriptor) { |
|
236 | 236 | return $this->isWebsocket($descriptor); |
237 | 237 | }; |
238 | 238 | |
@@ -295,7 +295,7 @@ discard block |
||
295 | 295 | */ |
296 | 296 | protected function bindRoom(): void |
297 | 297 | { |
298 | - $this->app->singleton(RoomContract::class, function (Container $container) { |
|
298 | + $this->app->singleton(RoomContract::class, function(Container $container) { |
|
299 | 299 | $driver = $container->make('config')->get('swoole_websocket.default'); |
300 | 300 | $settings = $container->make('config')->get("swoole_websocket.settings.{$driver}"); |
301 | 301 | $className = $container->make('config')->get("swoole_websocket.drivers.{$driver}"); |
@@ -311,7 +311,7 @@ discard block |
||
311 | 311 | */ |
312 | 312 | protected function bindWebsocket() |
313 | 313 | { |
314 | - $this->app->singleton(Websocket::class, function (Container $app) { |
|
314 | + $this->app->singleton(Websocket::class, function(Container $app) { |
|
315 | 315 | return new Websocket($app->make('swoole.room'), new Pipeline($app)); |
316 | 316 | }); |
317 | 317 |
@@ -58,7 +58,7 @@ |
||
58 | 58 | protected function bindSwooleTable() |
59 | 59 | { |
60 | 60 | if (!$this->app instanceof ConsoleApp) { |
61 | - $this->app->singleton(SwooleTable::class, function () { |
|
61 | + $this->app->singleton(SwooleTable::class, function() { |
|
62 | 62 | return $this->table; |
63 | 63 | }); |
64 | 64 |