Revert "Revert "Revert "Basic routing"" (#46)"

This reverts commit e99363d.

composer.json

@@ -16,7 +16,7 @@
   ],
   "require": {
     "php": "^5.6 || ^7.0",
-    "reactivex/rxphp": "1.5.3",
+    "reactivex/rxphp": "^1.1",
     "react/react": "0.4.2",
     "ramsey/uuid": "^3.5.1",
     "nikic/fast-route": "^1.2",

examples/router.php

@@ -0,0 +1,51 @@
+<?php
+use EventLoop\EventLoop;
+use Rxnet\Routing\RoutableSubject;
+
+require __DIR__ . "/../vendor/autoload.php";
+
+$loop = EventLoop::getLoop();
+$router = new \Rxnet\Routing\Router();
+
+// I'll get id and title as labels
+$router->route("/articles/{id}/{title}", ['method'=>'get'])
+    ->subscribeCallback(function (RoutableSubject $subject) use ($loop) {
+        $i = 0;
+        $loop->addPeriodicTimer(1, function(\React\EventLoop\Timer\Timer $timer) use(&$i, $subject) {
+            $i++;
+            echo ".";
+            $subject->onNext("Coucou {$i}");
+            if($i == 5 ) {
+                echo "#";
+                $timer->cancel();
+                $subject->onCompleted();
+            }
+        });
+    });
+$router->route("/articles/{id}/{title}", ['method'=>'post'])
+    ->subscribeCallback(function (RoutableSubject $subject) use ($loop) {
+        $subject->onNext("Coucou post");
+        $subject->onCompleted();
+    });
+/*$router->route('/articles/{id:\d+}')
+    ->subscribeCallback(function() {
+        //var_dump(func_get_args());
+    });
+*/
+
+$zmq = new \Rxnet\Zmq\RxZmq($loop);
+$dealer = $zmq->dealer("tcp://127.0.0.1:8081");
+$dealer->subscribe($router);
+
+$httpd = new \Rxnet\Httpd\Httpd();
+$httpd->map(new \Rxnet\Httpd\Strategies\StreamingResponseRouting())
+    ->subscribe($router);
+
+$httpd->listen(8080);
+
+
+$loop->run();
+
+//$router->onNext(new \Rxnet\Event\Event("/articles/233", 'coucou'));
+
+//$router->onNext(new \Rxnet\Event\Event("/articles/238/superbe", 'ici'));