()
| 651 | self.loop.run_until_complete(consume()) |
| 652 | |
| 653 | async def test_2(): |
| 654 | g1 = ait_class() |
| 655 | self.assertEqual(await anext(g1), 1) |
| 656 | self.assertEqual(await anext(g1), 2) |
| 657 | with self.assertRaises(StopAsyncIteration): |
| 658 | await anext(g1) |
| 659 | with self.assertRaises(StopAsyncIteration): |
| 660 | await anext(g1) |
| 661 | |
| 662 | g2 = ait_class() |
| 663 | self.assertEqual(await anext(g2, "default"), 1) |
| 664 | self.assertEqual(await anext(g2, "default"), 2) |
| 665 | self.assertEqual(await anext(g2, "default"), "default") |
| 666 | self.assertEqual(await anext(g2, "default"), "default") |
| 667 | |
| 668 | return "completed" |
| 669 | |
| 670 | result = self.loop.run_until_complete(test_2()) |
| 671 | self.assertEqual(result, "completed") |
nothing calls this directly
no test coverage detected