Lines Matching refs:await
31 await asyncio.sleep(0)
36 self.assertEqual(0, await getter)
45 await asyncio.sleep(0)
57 await self._test_repr_or_str(repr, True)
60 await self._test_repr_or_str(str, False)
70 await q.put(1)
72 self.assertEqual(1, await q.get())
80 await q.put(1)
86 await q.put(i)
88 items = [await q.get() for _ in range(3)]
98 await q.put(i)
104 await asyncio.sleep(0)
108 self.assertEqual(0, await q.get())
111 await asyncio.sleep(0)
113 self.assertEqual(1, await q.get())
114 self.assertEqual(2, await q.get())
126 self.assertEqual(1, await q.get())
132 await q.put(1)
137 self.assertEqual(1, await q.get())
150 res = await q.get()
155 await started.wait()
158 res = await queue_get_task
177 await asyncio.sleep(0)
179 await asyncio.sleep(0)
181 await q.put('a')
182 await asyncio.sleep(0)
183 self.assertEqual('a', await t2)
189 self.assertEqual(await q.get(), 'a')
190 self.assertEqual(await q.get(), 'b')
195 await queue.get()
199 await queue.put(i)
212 await asyncio.wait_for(queue.get(), 0.1)
223 await q.put(1)
224 self.assertEqual(1, await q.get())
234 await q.put(1)
235 await q.put(2)
241 await started.wait()
243 await queue_put_task
256 await asyncio.sleep(0)
263 await reader
267 await reader
281 await asyncio.sleep(0)
288 await reader1
290 await reader3
302 await asyncio.sleep(0)
309 await writer
313 await writer
333 await q.put(1)
334 await q.put(2)
341 await q.put(1)
346 self.assertEqual(1, await q.get())
357 await asyncio.sleep(0)
362 await asyncio.sleep(0)
365 await asyncio.sleep(0)
368 await put_b
373 await asyncio.sleep(0)
374 await q.put('a')
375 self.assertEqual(await t, 'a')
381 await queue.put(item)
384 await asyncio.sleep(0)
403 await asyncio.sleep(0)
410 await put_task
420 await asyncio.sleep(0)
432 await put_task
440 await q.put(i)
442 items = [await q.get() for _ in range(3)]
451 await q.put(i)
453 items = [await q.get() for _ in range(3)]
480 item = await q.get()
488 await q.join()
502 await q.join()
503 await q.join()