Add an example for Predis\DispatcherLoop.

examples/DispatcherLoop.php

@@ -0,0 +1,64 @@
+<?php
+
+require 'SharedConfigurations.php';
+
+/*
+This is a basic example on how to use the Predis\DispatcherLoop class.
+
+To see this example in action you can just use redis-cli and publish some 
+messages to the 'events' and 'control' channel, e.g.:
+
+./redis-cli
+PUBLISH events first
+PUBLISH events second
+PUBLISH events third
+PUBLISH control terminate_dispatcher
+*/
+
+// Create a client and disable r/w timeout on the socket
+$client = new Predis\Client($single_server + array('read_write_timeout' => 0));
+
+// Create a Predis\DispatcherLoop instance and attach a bunch of callbacks.
+$dispatcher = new Predis\DispatcherLoop($client);
+
+// Demonstrate how to use a callable class as a callback for Predis\DispatcherLoop.
+class EventsListener implements Countable {
+    private $_events;
+
+    public function __construct() {
+        $this->_events = array();
+    }
+
+    public function count() {
+        return count($this->_events);
+    }
+
+    public function getEvents() {
+        return $this->_events;
+    }
+
+    public function __invoke($payload) {
+        $this->_events[] = $payload;
+    }
+}
+
+// Attach our callable class to the dispatcher.
+$dispatcher->attachCallback('events', ($events = new EventsListener()));
+
+// Attach a function to control the dispatcher loop termination with a message.
+$dispatcher->attachCallback('control', function($payload) use ($dispatcher) {
+    if ($payload === 'terminate_dispatcher') {
+        $dispatcher->stop();
+    }
+});
+
+// Run the dispatcher loop until the callback attached to the 'control' channel
+// receives 'terminate_dispatcher' as a message.
+$dispatcher->run();
+
+// Display our achievements!
+echo "We received {$events->count()} messages!\n";
+
+// Say goodbye :-)
+$info = $client->info();
+print_r("Goodbye from Redis v{$info['redis_version']}!\n");