RegisterObservable should use flatMap instead of flatMapLatest

voryx · Sep 27, 2016 · b2df7f3 · b2df7f3
1 parent 9957bc9
commit b2df7f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Observable/RegisterObservable.php b/src/Observable/RegisterObservable.php
@@ -93,7 +93,7 @@ function () use (&$completed, $observer, $unregister) {
             ), $scheduler);
 
         $invocationSubscription = $invocationMsg
-            ->flatMapLatest(function (InvocationMessage $msg) {
+            ->flatMap(function (InvocationMessage $msg) {
 
                 try {
                     if ($this->extended) {