Fixed lint and mypy issues

promise/async_.py

@@ -1,15 +1,14 @@
-from threading import Timer, Thread
+# from threading import Timer, Thread
 
 from .compat import Queue
-from .context import Context
+# from .context import Context
 
 # Based on https://github.com/petkaantonov/bluebird/blob/master/src/async.js
 
 
 class Scheduler(object):
 
-    def call(self, fn):
-
+    def call(self, fn):        
         # thread = Thread(target=fn)
         # thread = Timer(0.001, fn)
         # fn = thread.start
@@ -18,7 +17,7 @@ def call(self, fn):
             # if not c:
             fn()
             # else:
-                # c.on_exit(fn)
+            #     c.on_exit(fn)
         except:
             pass
         # thread = Thread(target=fn)
@@ -72,8 +71,8 @@ def invoke_later(self, fn, context):
         else:
             self.schedule.call_later(0.1, fn)
 
-    def invoke(self, fn, context, with_trampoline=None):
-        if with_trampoline or (self.trampoline_enabled and with_trampoline != False):
+    def invoke(self, fn, context):
+        if self.trampoline_enabled:
             self._async_invoke(fn, context)
         else:
             self.schedule.call(

promise/context.py

@@ -1,13 +1,18 @@
 context_stack = []
 
+from typing import Callable
+
+
 class Context(object):
 
     __slots__ = ('_parent', '_exited', '_exit_fns')
 
     def __init__(self):
         self._parent = self.peek_context()
+        if self._parent:
+            self._parent.on_exit(self._exit)
         self._exited = False
-        self._exit_fns = []
+        self._exit_fns = [] # type: List[Callable]
 
     def push_context(self):
         # if self._trace:
@@ -20,9 +25,13 @@ def __enter__(self):
 
     def __exit__(self, type, value, traceback):
         assert not self._exited, "Can't exit a Context twice"
-        self.pop_context()
-        self._exited = True
-        self.drain_queue()
+        self._exit()
+
+    def _exit(self):
+        if not self._exited:
+            self._exited = True
+            self.pop_context()
+            self.drain_queue()
 
     def drain_queue(self):
         exit_fns = self._exit_fns

promise/promise.py

@@ -103,7 +103,7 @@ def __init__(self, executor=None):
         self._rejection_handler0 = None  # type: Union[Callable, partial]
         self._promise0 = None  # type: Promise
         self._future = None  # type: Future
-        self._event_instance = None
+        self._event_instance = None # type: Event
         self._trace = Context.peek_context()
 
         self._is_waiting = False

promise/promise_list.py

@@ -53,7 +53,7 @@ def _iterate(self, values):
         Promise = self._promise_class
         is_resolved = False
         self._length = len(values)
-        self._values = [ None ] * self._length
+        self._values = [None] * self._length
 
         result = self.promise