Blame SOURCES/await.patch
|
 |
1bff74 |
diff -ru txaio-2.10.0/test/test_gather.py txaio-2.10.0_patched/test/test_gather.py
|
|
|
1bff74 |
--- txaio-2.10.0/test/test_gather.py 2018-03-02 08:04:45.000000000 +0100
|
|
|
1bff74 |
+++ txaio-2.10.0_patched/test/test_gather.py 2018-08-01 13:03:40.237465405 +0200
|
|
|
1bff74 |
@@ -26,7 +26,7 @@
|
|
|
1bff74 |
|
|
|
1bff74 |
import txaio
|
|
|
1bff74 |
|
|
|
1bff74 |
-from util import await
|
|
|
1bff74 |
+from util import await_completion
|
|
|
1bff74 |
|
|
|
1bff74 |
|
|
|
1bff74 |
def test_gather_two(framework):
|
|
|
1bff74 |
@@ -61,7 +61,7 @@
|
|
|
1bff74 |
txaio.add_callbacks(f2, done, error)
|
|
|
1bff74 |
|
|
|
1bff74 |
for f in [f0, f1, f2]:
|
|
|
1bff74 |
- await(f)
|
|
|
1bff74 |
+ await_completion(f)
|
|
|
1bff74 |
|
|
|
1bff74 |
assert len(results) == 1
|
|
|
1bff74 |
assert len(errors) == 0
|
|
|
1bff74 |
@@ -99,7 +99,7 @@
|
|
|
1bff74 |
# out of "run_until_complete()" as well; fix util.py?
|
|
|
1bff74 |
for f in [f0, f1, f2]:
|
|
|
1bff74 |
try:
|
|
|
1bff74 |
- await(f)
|
|
|
1bff74 |
+ await_completion(f)
|
|
|
1bff74 |
except Exception:
|
|
|
1bff74 |
pass
|
|
|
1bff74 |
|
|
|
1bff74 |
Only in txaio-2.10.0_patched/test: .test_gather.py.swp
|
|
|
1bff74 |
diff -ru txaio-2.10.0/test/util.py txaio-2.10.0_patched/test/util.py
|
|
|
1bff74 |
--- txaio-2.10.0/test/util.py 2017-04-15 16:17:17.000000000 +0200
|
|
|
1bff74 |
+++ txaio-2.10.0_patched/test/util.py 2018-08-01 13:02:30.099152902 +0200
|
|
|
1bff74 |
@@ -57,7 +57,7 @@
|
|
|
1bff74 |
asyncio.gather(*asyncio.Task.all_tasks())
|
|
|
1bff74 |
|
|
|
1bff74 |
|
|
|
1bff74 |
-def await(future):
|
|
|
1bff74 |
+def await_completion(future):
|
|
|
1bff74 |
'''
|
|
|
1bff74 |
Essentially just a way to call "run_until_complete" that becomes a
|
|
|
1bff74 |
no-op if we're using Twisted.
|
|
|
1bff74 |
Only in txaio-2.10.0_patched/test: .util.py.swp
|