()
| 595 | stream = asyncio.StreamReader(loop=self.loop) |
| 596 | |
| 597 | async def set_err(): |
| 598 | stream.set_exception(ValueError()) |
| 599 | |
| 600 | t1 = self.loop.create_task(stream.readline()) |
| 601 | t2 = self.loop.create_task(set_err()) |
nothing calls this directly
no test coverage detected