Lines Matching refs:_core

5 from ... import _core
14     q = _core.UnboundedQueue()
17     with pytest.raises(_core.WouldBlock):
40     q = _core.UnboundedQueue()
55         async with _core.open_nursery() as nursery:
57             await _core.wait_all_tasks_blocked()
63             await _core.wait_all_tasks_blocked()
65             await _core.wait_all_tasks_blocked()
71     q = _core.UnboundedQueue()
86     async with _core.open_nursery() as nursery:
88         await _core.wait_all_tasks_blocked()
91         with pytest.raises(_core.WouldBlock):
102     async with _core.open_nursery() as nursery:
104         await _core.wait_all_tasks_blocked()
106         await _core.wait_all_tasks_blocked()
110             await _core.wait_all_tasks_blocked()
118     q = _core.UnboundedQueue()
139     async with _core.open_nursery() as nursery:
140         q = _core.UnboundedQueue()