added fallback definition of _timeout_handle to OnEmitFuture

semiversus · Sep 18, 2018 · 3b9efa1 · 3b9efa1
1 parent d9d6d9e
commit 3b9efa1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/broqer/op/subscribers/on_emit_future.py b/broqer/op/subscribers/on_emit_future.py
@@ -43,6 +43,8 @@ def __init__(self, timeout=None, loop=None):
         if timeout is not None:
             self._timeout_handle = loop.call_later(
                 timeout, self.set_exception, asyncio.TimeoutError)
+        else:
+            self._timeout_handle = None
 
         self._disposable = None