FM / Connections

/var/www/flurhymez/vendor/laravel/framework/src/Illuminate/Redis/Connections/

/var/www/flurhymez/vendor/laravel/framework/src/Illuminate/Redis/Connections

Name	Size	Mode	Actions
Connection.php	4998	0644	edit dl rm
PhpRedisClusterConnection.php	118	0644	edit dl rm
PhpRedisConnection.php	14471	0644	edit dl rm
PredisClusterConnection.php	114	0644	edit dl rm
PredisConnection.php	1675	0644	edit dl rm

Edit: /var/www/flurhymez/vendor/laravel/framework/src/Illuminate/Redis/Connections/PredisConnection.php (1675B)

<?php

namespace Illuminate\Redis\Connections;

use Closure;
use Illuminate\Contracts\Redis\Connection as ConnectionContract;
use Predis\Command\ServerFlushDatabase;
use Predis\Connection\Aggregate\ClusterInterface;

/**
 * @mixin \Predis\Client
 */
class PredisConnection extends Connection implements ConnectionContract
{
    /**
     * The Predis client.
     *
     * @var \Predis\Client
     */
    protected $client;

/**
     * 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();

$loop->{$method}(...array_values((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);
        }
    }
}

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(); $loop->{$method}(...array_values((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); } } }