fixed syntax style in map_async.py

semiversus · Jun 8, 2018 · 3523a3b · 3523a3b
1 parent 0a3838e
commit 3523a3b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broqer/op/map_async.py b/broqer/op/map_async.py
@@ -137,7 +137,7 @@ def __init__(self, publisher: Publisher, map_coro, *args,
         self._mode = mode
         self._error_callback = error_callback
         self._future = None  # type: asyncio.Future
-        self._last_emit = None # type: Any
+        self._last_emit = None  # type: Any
 
         if mode in (Mode.QUEUE, Mode.LAST, Mode.LAST_DISTINCT):
             maxlen = (None if mode == Mode.QUEUE else 1)