Lines Matching refs:self

14     async def _test_repr_or_str(self, fn, expect_id):
21         self.assertTrue(fn(q).startswith('<Queue'), fn(q))
23         self.assertEqual(expect_id, id_is_present)
32             self.assertTrue('_getters[1]' in fn(q))
36         self.assertEqual(0, await getter)
46             self.assertTrue('_putters[1]' in fn(q))
50         self.assertTrue(putter.done())
54         self.assertTrue('_queue=[1]' in fn(q))
56     async def test_repr(self):
57         await self._test_repr_or_str(repr, True)
59     async def test_str(self):
60         await self._test_repr_or_str(str, False)
62     def test_generic_alias(self):
64         self.assertEqual(q.__args__, (int,))
65         self.assertIsInstance(q, GenericAlias)
67     async def test_empty(self):
69         self.assertTrue(q.empty())
71         self.assertFalse(q.empty())
72         self.assertEqual(1, await q.get())
73         self.assertTrue(q.empty())
75     async def test_full(self):
77         self.assertFalse(q.full())
81         self.assertTrue(q.full())
83     async def test_order(self):
89         self.assertEqual([1, 3, 2], items)
91     async def test_maxsize(self):
93         self.assertEqual(2, q.maxsize)
107         self.assertEqual([0, 1], have_been_put)
108         self.assertEqual(0, await q.get())
112         self.assertEqual([0, 1, 2], have_been_put)
113         self.assertEqual(1, await q.get())
114         self.assertEqual(2, await q.get())
116         self.assertTrue(t.done())
117         self.assertTrue(t.result())
122     async def test_blocking_get(self):
126         self.assertEqual(1, await q.get())
128     async def test_get_with_putters(self):
137         self.assertEqual(1, await q.get())
138         self.assertTrue(waiter.done())
139         self.assertIsNone(waiter.result())
141     async def test_blocking_get_wait(self):
156         self.assertFalse(finished)
159         self.assertTrue(finished)
160         self.assertEqual(1, res)
162     def test_nonblocking_get(self):
165         self.assertEqual(1, q.get_nowait())
167     def test_nonblocking_get_exception(self):
169         self.assertRaises(asyncio.QueueEmpty, q.get_nowait)
171     async def test_get_cancelled_race(self):
180         self.assertTrue(t1.done())
183         self.assertEqual('a', await t2)
185     async def test_get_with_waiting_putters(self):
189         self.assertEqual(await q.get(), 'a')
190         self.assertEqual(await q.get(), 'b')
192     async def test_why_are_getters_waiting(self):
208     async def test_cancelled_getters_not_being_held_in_self_getters(self):
211         with self.assertRaises(TimeoutError):
214         self.assertEqual(len(queue._getters), 0)
219     async def test_blocking_put(self):
224         self.assertEqual(1, await q.get())
226     async def test_blocking_put_wait(self):
242         self.assertFalse(finished)
244         self.assertTrue(finished)
246     def test_nonblocking_put(self):
249         self.assertEqual(1, q.get_nowait())
251     async def test_get_cancel_drop_one_pending_reader(self):
271         self.assertEqual(1, result)
273     async def test_get_cancel_drop_many_pending_readers(self):
287             with self.assertRaises(asyncio.CancelledError):
293         self.assertEqual({reader2.result(), reader3.result()}, {1, 2})
295     async def test_put_cancel_drop(self):
305         self.assertEqual(value1, 1)
316         self.assertEqual(value2, 2)
317         self.assertEqual(q.qsize(), 0)
319     def test_nonblocking_put_exception(self):
322         self.assertRaises(asyncio.QueueFull, q.put_nowait, 2)
324     async def test_float_maxsize(self):
328         self.assertTrue(q.full())
329         self.assertRaises(asyncio.QueueFull, q.put_nowait, 3)
335         self.assertTrue(q.full())
337     async def test_put_cancelled(self):
346         self.assertEqual(1, await q.get())
347         self.assertTrue(t.done())
348         self.assertTrue(t.result())
350     async def test_put_cancelled_race(self):
358         self.assertTrue(put_a.done())
359         self.assertFalse(put_b.done())
363         self.assertTrue(put_c.done())
364         self.assertEqual(q.get_nowait(), 'a')
366         self.assertEqual(q.get_nowait(), 'b')
370     async def test_put_with_waiting_getters(self):
375         self.assertEqual(await t, 'a')
377     async def test_why_are_putters_waiting(self):
396     async def test_cancelled_puts_not_being_held_in_self_putters(self):
407         self.assertEqual(len(queue._putters), 1)
409         with self.assertRaises(asyncio.CancelledError):
411         self.assertEqual(len(queue._putters), 0)
413     async def test_cancelled_put_silence_value_error_exception(self):
425         # self._putters but it was removed previously by queue.get_nowait().
431         with self.assertRaises(asyncio.CancelledError):
437     async def test_order(self):
443         self.assertEqual([2, 3, 1], items)
448     async def test_order(self):
454         self.assertEqual([1, 2, 3], items)
461     def test_task_done_underflow(self):
462         q = self.q_class()
463         self.assertRaises(ValueError, q.task_done)
465     async def test_task_done(self):
466         q = self.q_class()
489             self.assertEqual(sum(range(100)), accumulator)
496     async def test_join_empty_queue(self):
497         q = self.q_class()
505     async def test_format(self):
506         q = self.q_class()
507         self.assertEqual(q._format(), 'maxsize=0')
510         self.assertEqual(q._format(), 'maxsize=0 tasks=2')