From ce7dfd8ef002bffcf1ce0e5bd369d8c113c7b3fc Mon Sep 17 00:00:00 2001 From: etienne Date: Fri, 28 Jul 2017 08:00:55 +0200 Subject: [PATCH] fix Router --- composer.json | 2 +- src/Rxnet/Routing/Router.php | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/composer.json b/composer.json index c4c9179..136c46e 100644 --- a/composer.json +++ b/composer.json @@ -1,7 +1,7 @@ { "name": "domraider/rxnet", "description": "Rx connector for PHP", - "version": "0.6.8", + "version": "0.6.9", "keywords": [ "rabbit", "queue", diff --git a/src/Rxnet/Routing/Router.php b/src/Rxnet/Routing/Router.php index a15eeaa..8ae59d3 100644 --- a/src/Rxnet/Routing/Router.php +++ b/src/Rxnet/Routing/Router.php @@ -113,7 +113,7 @@ public function onNext($value) $labels = array_merge($labels, $vars); $value->setLabels($labels); $subject->onNext($value); - $subject->subscribe($value); + return; } }