ReactPHP Redis Pub/Sub

react_redis_pubsub.php

<?php   
error_reporting(E_ALL);
ini_set("display_errors", 1);
ini_set("default_socket_timeout", 10);

require __DIR__ . "/../../vendor/autoload.php";

$loop = React\EventLoop\Factory::create();
$factory = new Factory($loop);

$channel = isset($argv[1]) ? $argv[1] : "default";

$factory->createClient("redis://:[email protected]:6379")->then(function (Clue\React\Redis\Client $client) use ($channel) {
    $client->subscribe($channel)->then(function () use (&$channel) {
        echo "Now subscribed to $channel " . PHP_EOL;
    });
    $client->on("message", function ($channel, $message) {
        echo 'Message on ' . $channel . ': ' . $message . PHP_EOL;
    });
}, function (Exception $e) {
    print $e->getMessage() . "\n";
});

$loop->run();