return possible futures on topic.emit

semiversus · Jun 15, 2018 · 0629a88 · 0629a88
1 parent c1d0046
commit 0629a88
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broqer/hub.py b/broqer/hub.py
@@ -146,7 +146,7 @@ def emit(self, *args: Any, who: Optional[Publisher]=None) -> None:
         elif who == self._subject:
             self._emit(*args)
         else:
-            self._subject.emit(*args, who=self)
+            return self._subject.emit(*args, who=self)
 
     def __call__(self, *args, **kwargs) -> None:
         raise TypeError('Topic is not callable (for use with | operator).' +