Lines Matching refs:get
28 # Start a task that waits to get.
29 getter = tg.create_task(q.get())
33 # resume q.get coroutine to finish generator
72 self.assertEqual(1, await q.get())
88 items = [await q.get() for _ in range(3)]
108 self.assertEqual(0, await q.get())
113 self.assertEqual(1, await q.get())
114 self.assertEqual(2, await q.get())
126 self.assertEqual(1, await q.get())
137 self.assertEqual(1, await q.get())
150 res = await q.get()
174 t1 = asyncio.create_task(q.get())
175 t2 = asyncio.create_task(q.get())
189 self.assertEqual(await q.get(), 'a')
190 self.assertEqual(await q.get(), 'b')
195 await queue.get()
212 await asyncio.wait_for(queue.get(), 0.1)
224 self.assertEqual(1, await q.get())
254 reader = asyncio.create_task(q.get())
266 reader = asyncio.create_task(q.get())
270 # if we get 2, it means 1 got dropped!
277 reader1 = tg.create_task(q.get())
278 reader2 = tg.create_task(q.get())
279 reader3 = tg.create_task(q.get())
346 self.assertEqual(1, await q.get())
372 t = asyncio.create_task(q.get())
442 items = [await q.get() for _ in range(3)]
453 items = [await q.get() for _ in range(3)]
472 # Two workers get items from the queue and call task_done after each.
480 item = await q.get()