goodbye stuff

[dotfiles/.git] / .local / lib / python2.7 / site-packages / trollius / executor.py

diff --git a/.local/lib/python2.7/site-packages/trollius/executor.py b/.local/lib/python2.7/site-packages/trollius/executor.py
deleted file mode 100644 (file)
index 9e7fdd7..0000000
--- a/.local/lib/python2.7/site-packages/trollius/executor.py
+++ /dev/null
@@ -1,84 +0,0 @@
-from .log import logger
-
-__all__ = (
-    'CancelledError', 'TimeoutError',
-    'FIRST_COMPLETED', 'FIRST_EXCEPTION', 'ALL_COMPLETED',
-    )
-
-# Argument for default thread pool executor creation.
-_MAX_WORKERS = 5
-
-try:
-    import concurrent.futures
-    import concurrent.futures._base
-except ImportError:
-    FIRST_COMPLETED = 'FIRST_COMPLETED'
-    FIRST_EXCEPTION = 'FIRST_EXCEPTION'
-    ALL_COMPLETED = 'ALL_COMPLETED'
-
-    class Future(object):
-        def __init__(self, callback, args):
-            try:
-                self._result = callback(*args)
-                self._exception = None
-            except Exception as err:
-                self._result = None
-                self._exception = err
-            self.callbacks = []
-
-        def cancelled(self):
-            return False
-
-        def done(self):
-            return True
-
-        def exception(self):
-            return self._exception
-
-        def result(self):
-            if self._exception is not None:
-                raise self._exception
-            else:
-                return self._result
-
-        def add_done_callback(self, callback):
-            callback(self)
-
-    class Error(Exception):
-        """Base class for all future-related exceptions."""
-        pass
-
-    class CancelledError(Error):
-        """The Future was cancelled."""
-        pass
-
-    class TimeoutError(Error):
-        """The operation exceeded the given deadline."""
-        pass
-
-    class SynchronousExecutor:
-        """
-        Synchronous executor: submit() blocks until it gets the result.
-        """
-        def submit(self, callback, *args):
-            return Future(callback, args)
-
-        def shutdown(self, wait):
-            pass
-
-    def get_default_executor():
-        logger.error("concurrent.futures module is missing: "
-                     "use a synchrounous executor as fallback!")
-        return SynchronousExecutor()
-else:
-    FIRST_COMPLETED = concurrent.futures.FIRST_COMPLETED
-    FIRST_EXCEPTION = concurrent.futures.FIRST_EXCEPTION
-    ALL_COMPLETED = concurrent.futures.ALL_COMPLETED
-
-    Future = concurrent.futures.Future
-    Error = concurrent.futures._base.Error
-    CancelledError = concurrent.futures.CancelledError
-    TimeoutError = concurrent.futures.TimeoutError
-
-    def get_default_executor():
-        return concurrent.futures.ThreadPoolExecutor(_MAX_WORKERS)