Skip to content

Commit

Permalink
blacken
Browse files Browse the repository at this point in the history
  • Loading branch information
oremanj committed May 29, 2020
1 parent 204fb41 commit 3b7f2f8
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions trio/_core/tests/test_asyncgen.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
from ... import _core
from .tutil import gc_collect_harder


def test_asyncgen_basics():
collected = []

Expand Down Expand Up @@ -107,9 +108,7 @@ def abort_fn(_):
abort_fn.aiter = aiter

async with _core.open_nursery() as nursery:
nursery.start_soon(
_core.wait_task_rescheduled, abort_fn
)
nursery.start_soon(_core.wait_task_rescheduled, abort_fn)
await _core.wait_all_tasks_blocked()
nursery.cancel_scope.deadline = _core.current_time()

Expand Down Expand Up @@ -206,6 +205,7 @@ async def async_main():
# queue that we won't start pumping until later. (Without this, it's
# basically impossible to reproduce the race reliably.)
from .._entry_queue import EntryQueue

extra_queue = EntryQueue()
_core._run.GLOBAL_RUN_CONTEXT.runner.asyncgen_manager.entry_queue = extra_queue

Expand Down

0 comments on commit 3b7f2f8

Please sign in to comment.