diff options
| author |   Zac Medico <zmedico@gentoo.org> | 2017-03-25 17:45:52 -0700 |
|---|---|---|
| committer | Zac Medico <zmedico@gentoo.org> | 2017-03-26 13:05:46 -0700 |
| commit | 4b12ed04ec6b99f5a948e0eea5778a4fac502740 (patch) | |
| tree | 834b8d84bfb819e4b6b81bc634280f67ba812129 /pym/portage/tests/ebuild/test_ipc_daemon.py | |
| parent | phase-helpers.sh: Loop over A rather than SRC_URI in __eapi0_pkg_nofetch. (diff) | |
| download | portage-4b12ed04ec6b99f5a948e0eea5778a4fac502740.tar.gz portage-4b12ed04ec6b99f5a948e0eea5778a4fac502740.tar.bz2 portage-4b12ed04ec6b99f5a948e0eea5778a4fac502740.zip | |
Future: implement add_done_callback for asyncio compat (bug 591760)
Implement the add_done_callback and remove_done_callback methods, since
they are required in order to make further progress toward asyncio
compatibility.
Also implement the AbstractEventLoop create_future method for the
EventLoop class, so that it returns an instance of _EventLoopFuture.
EventLoop currently does not implement some of the
asyncio.AbstractEventLoop methods that asyncio.Future requires for
its add_done_callback implementation, and the create_future method
conveniently solves this problem.
X-Gentoo-bug: 591760
X-Gentoo-bug-url: https://bugs.gentoo.org/show_bug.cgi?id=591760
Acked-by: Brian Dolbec <dolsen@gentoo.org>
Diffstat (limited to 'pym/portage/tests/ebuild/test_ipc_daemon.py')
| -rw-r--r-- | pym/portage/tests/ebuild/test_ipc_daemon.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/pym/portage/tests/ebuild/test_ipc_daemon.py b/pym/portage/tests/ebuild/test_ipc_daemon.py index 68f139aa4..fc7916541 100644 --- a/pym/portage/tests/ebuild/test_ipc_daemon.py +++ b/pym/portage/tests/ebuild/test_ipc_daemon.py @@ -16,7 +16,6 @@ from portage.util import ensure_dirs from portage.util._async.ForkProcess import ForkProcess from portage.util._async.TaskScheduler import TaskScheduler from portage.util._eventloop.global_event_loop import global_event_loop -from portage.util.futures.futures import Future from _emerge.SpawnProcess import SpawnProcess from _emerge.EbuildBuildDir import EbuildBuildDir from _emerge.EbuildIpcDaemon import EbuildIpcDaemon @@ -150,7 +149,7 @@ class IpcDaemonTestCase(TestCase): self._run_done.set_result(True) def _run(self, event_loop, task_scheduler, timeout): - self._run_done = Future() + self._run_done = event_loop.create_future() timeout_id = event_loop.timeout_add(timeout, self._timeout_callback, task_scheduler) task_scheduler.addExitListener(self._exit_callback) |