upgrade Routablesubject to allow removal of all observers

Domraider · May 2, 2017 · 2c92bbe · 2c92bbe
1 parent 06d0ce2
commit 2c92bbe
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/composer.json b/composer.json
@@ -1,7 +1,7 @@
 {
   "name": "domraider/rxnet",
   "description": "Rx connector for PHP",
-  "version": "0.6.2",
+  "version": "0.6.3",
   "keywords": [
     "rabbit",
     "queue",

diff --git a/src/Rxnet/Routing/RoutableSubject.php b/src/Rxnet/Routing/RoutableSubject.php
@@ -72,4 +72,9 @@ public function setLabels($labels)
     {
         $this->labels = $labels;
     }
+
+    public function removeObservers()
+    {
+        $this->observers  = [];
+    }
 }