]> granicus.if.org Git - python/commitdiff
asyncio: Don't export BaseEventLoop, BaseSelectorEventLoop nor
authorVictor Stinner <victor.stinner@gmail.com>
Sat, 25 Jan 2014 21:22:18 +0000 (22:22 +0100)
committerVictor Stinner <victor.stinner@gmail.com>
Sat, 25 Jan 2014 21:22:18 +0000 (22:22 +0100)
BaseProactorEventLoop

Import them from submodules if you really need them.

Lib/asyncio/__init__.py
Lib/test/test_asyncio/test_base_events.py
Lib/test/test_asyncio/test_events.py
Lib/test/test_asyncio/test_proactor_events.py
Lib/test/test_asyncio/test_selector_events.py

index 95235dcfa2c711ad98c42774693e859b43ab7298..eb22c385b8f29559612ab1b16f7e31a8049b955c 100644 (file)
@@ -18,14 +18,11 @@ if sys.platform == 'win32':
         import _overlapped  # Will also be exported.
 
 # This relies on each of the submodules having an __all__ variable.
-from .base_events import *
 from .events import *
 from .futures import *
 from .locks import *
-from .proactor_events import *
 from .protocols import *
 from .queues import *
-from .selector_events import *
 from .streams import *
 from .tasks import *
 from .transports import *
@@ -36,14 +33,11 @@ else:
     from .unix_events import *  # pragma: no cover
 
 
-__all__ = (base_events.__all__ +
-           events.__all__ +
+__all__ = (events.__all__ +
            futures.__all__ +
            locks.__all__ +
-           proactor_events.__all__ +
            protocols.__all__ +
            queues.__all__ +
-           selector_events.__all__ +
            streams.__all__ +
            tasks.__all__ +
            transports.__all__)
index 8d0796ab7b81e8c74e7c7b6e9e9802e71d511627..9c2bda1f9678a6526949aa4dfc56b8d0450a117e 100644 (file)
@@ -9,6 +9,7 @@ import unittest.mock
 from test.support import find_unused_port, IPV6_ENABLED
 
 import asyncio
+from asyncio import base_events
 from asyncio import constants
 from asyncio import test_utils
 
@@ -16,7 +17,7 @@ from asyncio import test_utils
 class BaseEventLoopTests(unittest.TestCase):
 
     def setUp(self):
-        self.loop = asyncio.BaseEventLoop()
+        self.loop = base_events.BaseEventLoop()
         self.loop._selector = unittest.mock.Mock()
         asyncio.set_event_loop(None)
 
index 44879ffa7f1983daa06c69e1cb33d1fd99ddb279..bded1a3bf1e3337c69f764fe0918b0a95e198ee1 100644 (file)
@@ -25,6 +25,7 @@ from test import support  # find_unused_port, IPV6_ENABLED, TEST_HOME_DIR
 
 import asyncio
 from asyncio import events
+from asyncio import selector_events
 from asyncio import test_utils
 
 
@@ -902,7 +903,7 @@ class EventLoopTestsMixin:
 
     def test_internal_fds(self):
         loop = self.create_event_loop()
-        if not isinstance(loop, asyncio.BaseSelectorEventLoop):
+        if not isinstance(loop, selector_events.BaseSelectorEventLoop):
             self.skipTest('loop is not a BaseSelectorEventLoop')
 
         self.assertEqual(1, loop._internal_fds)
index 1c628000c5dff049da289caf99634bbd7258a06e..9964f425d21d9d7a2cd975b004cd35ce5ba0c4fd 100644 (file)
@@ -5,6 +5,7 @@ import unittest
 import unittest.mock
 
 import asyncio
+from asyncio.proactor_events import BaseProactorEventLoop
 from asyncio.proactor_events import _ProactorSocketTransport
 from asyncio.proactor_events import _ProactorWritePipeTransport
 from asyncio.proactor_events import _ProactorDuplexPipeTransport
@@ -344,18 +345,18 @@ class BaseProactorEventLoopTests(unittest.TestCase):
 
         self.ssock, self.csock = unittest.mock.Mock(), unittest.mock.Mock()
 
-        class EventLoop(asyncio.BaseProactorEventLoop):
+        class EventLoop(BaseProactorEventLoop):
             def _socketpair(s):
                 return (self.ssock, self.csock)
 
         self.loop = EventLoop(self.proactor)
 
-    @unittest.mock.patch.object(asyncio.BaseProactorEventLoop, 'call_soon')
-    @unittest.mock.patch.object(asyncio.BaseProactorEventLoop, '_socketpair')
+    @unittest.mock.patch.object(BaseProactorEventLoop, 'call_soon')
+    @unittest.mock.patch.object(BaseProactorEventLoop, '_socketpair')
     def test_ctor(self, socketpair, call_soon):
         ssock, csock = socketpair.return_value = (
             unittest.mock.Mock(), unittest.mock.Mock())
-        loop = asyncio.BaseProactorEventLoop(self.proactor)
+        loop = BaseProactorEventLoop(self.proactor)
         self.assertIs(loop._ssock, ssock)
         self.assertIs(loop._csock, csock)
         self.assertEqual(loop._internal_fds, 1)
@@ -398,7 +399,7 @@ class BaseProactorEventLoopTests(unittest.TestCase):
 
     def test_socketpair(self):
         self.assertRaises(
-            NotImplementedError, asyncio.BaseProactorEventLoop, self.proactor)
+            NotImplementedError, BaseProactorEventLoop, self.proactor)
 
     def test_make_socket_transport(self):
         tr = self.loop._make_socket_transport(self.sock, unittest.mock.Mock())
index 5a074aed491d74592a795b226de4db0972c0358c..4c81e75d220b45c72fd98d5d35fb1b5b6d08ce84 100644 (file)
@@ -16,13 +16,14 @@ except ImportError:
 import asyncio
 from asyncio import selectors
 from asyncio import test_utils
+from asyncio.selector_events import BaseSelectorEventLoop
 from asyncio.selector_events import _SelectorTransport
 from asyncio.selector_events import _SelectorSslTransport
 from asyncio.selector_events import _SelectorSocketTransport
 from asyncio.selector_events import _SelectorDatagramTransport
 
 
-class TestBaseSelectorEventLoop(asyncio.BaseSelectorEventLoop):
+class TestBaseSelectorEventLoop(BaseSelectorEventLoop):
 
     def _make_self_pipe(self):
         self._ssock = unittest.mock.Mock()