(self, *args, **kwargs)
| 20 | self.loop.close() |
| 21 | |
| 22 | def _make_one(self, *args, **kwargs): |
| 23 | return streams.StreamReader(loop=self.loop, *args, **kwargs) |
| 24 | |
| 25 | def test_create_waiter(self): |
| 26 | stream = self._make_one() |
no outgoing calls
no test coverage detected