Subversion-Projekte lars-tiefland.laravel_shop

<?php

namespace Illuminate\Redis\Connections;

use Closure;

use Illuminate\Contracts\Redis\Connection as ConnectionContract;

/**

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

    }

}