Make DummyFuture class private.

It's now only exposed and used when concurrent.futures is not available.

diff --git a/tornado/concurrent.py b/tornado/concurrent.py
index 19f1c87be8e3d7bd44588e9ca307e8de1879a267..e24a768ac8e25ba1816559b3207a6928a5a5259e 100644 (file)
--- a/tornado/concurrent.py
+++ b/tornado/concurrent.py
@@ -29,7 +29,7 @@ except ImportError:
 class ReturnValueIgnoredError(Exception):
     pass
 
-class DummyFuture(object):
+class _DummyFuture(object):
     def __init__(self):
         self._done = False
         self._result = None
@@ -87,7 +87,7 @@ class DummyFuture(object):
         self._callbacks = None
 
 if futures is None:
-    Future = DummyFuture
+    Future = _DummyFuture
 else:
     Future = futures.Future
 

diff --git a/tornado/ioloop.py b/tornado/ioloop.py
index 4062661b2ab550c68625fe8611134398247fd089..08e6d60f7694a1a2d1e72fddb84173970f4c7b8d 100644 (file)
--- a/tornado/ioloop.py
+++ b/tornado/ioloop.py
@@ -40,7 +40,7 @@ import threading
 import time
 import traceback
 
-from tornado.concurrent import DummyFuture
+from tornado.concurrent import Future
 from tornado.log import app_log, gen_log
 from tornado import stack_context
 from tornado.util import Configurable
@@ -50,11 +50,6 @@ try:
 except ImportError:
     signal = None
 
-try:
-    from concurrent import futures
-except ImportError:
-    futures = None
-
 try:
     import thread  # py2
 except ImportError:
@@ -352,17 +347,12 @@ class IOLoop(Configurable):
         """
         raise NotImplementedError()
 
-    if futures is not None:
-        _FUTURE_TYPES = (futures.Future, DummyFuture)
-    else:
-        _FUTURE_TYPES = DummyFuture
-
     def add_future(self, future, callback):
         """Schedules a callback on the IOLoop when the given future is finished.
 
         The callback is invoked with one argument, the future.
         """
-        assert isinstance(future, IOLoop._FUTURE_TYPES)
+        assert isinstance(future, Future)
         callback = stack_context.wrap(callback)
         future.add_done_callback(
             lambda future: self.add_callback(callback, future))