REDROOM

Edit File Size: 1.70 KB

/home/getspomw/royalsquad.us/vendor/laravel/framework/src/Illuminate/Redis/Connections/PredisConnection.php

Text Base64

<?php

namespace Illuminate\Redis\Connections;

use Closure;
use Illuminate\Contracts\Redis\Connection as ConnectionContract;
use Illuminate\Support\Collection;
use Predis\Command\Argument\ArrayableArgument;

/**
 * @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') {
                $callback($message->payload, $message->channel);
            }
        }

unset($loop);
    }

/**
     * Parse the command's parameters for event dispatching.
     *
     * @param  array  $parameters
     * @return array
     */
    protected function parseParametersForEvent(array $parameters)
    {
        return (new Collection($parameters))
            ->transform(function ($parameter) {
                return $parameter instanceof ArrayableArgument
                    ? $parameter->toArray()
                    : $parameter;
            })->all();
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
Connection.php	5.08 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
PacksPhpRedisValues.php	6.35 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
PhpRedisClusterConnection.php	1.88 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
PhpRedisConnection.php	14.03 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
PredisClusterConnection.php	600 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
PredisConnection.php	1.70 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive

Directory Contents