added missing applying map to op.CombineLatest on subscription (fixin…

…g issue #1)
semiversus · Jun 13, 2018 · 1832bce · 1832bce
1 parent 551d11d
commit 1832bce
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/broqer/op/combine_latest.py b/broqer/op/combine_latest.py
@@ -47,7 +47,10 @@ def __init__(self, *publishers: Publisher, map=None) -> None:
     def subscribe(self, subscriber: Subscriber) -> SubscriptionDisposable:
         disposable = MultiOperator.subscribe(self, subscriber)
         if not self._missing:
-            subscriber.emit(*self._cache, who=self)
+            if self._map:
+                self._emit(self._map(*self._cache))
+            else:
+                self._emit(*self._cache)
         return disposable
 
     def emit(self, *args: Any, who: Publisher) -> None: