test_streams.py - OpenGrok cross reference for /third_party/python/Lib/test/test_asyncio/test

Lines Matching refs:StreamReader
128         stream = asyncio.StreamReader(loop=self.loop)
134         stream = asyncio.StreamReader(loop=self.loop)
141         stream = asyncio.StreamReader(loop=self.loop)
150         stream = asyncio.StreamReader(loop=self.loop)
163         stream = asyncio.StreamReader(loop=self.loop)
174         stream = asyncio.StreamReader(loop=self.loop)
187         stream = asyncio.StreamReader(loop=self.loop)
202         stream = asyncio.StreamReader(loop=self.loop)
214             asyncio.StreamReader(limit=0, loop=self.loop)
217             asyncio.StreamReader(limit=-1, loop=self.loop)
220         stream = asyncio.StreamReader(limit=3, loop=self.loop)
229         stream = asyncio.StreamReader(loop=self.loop)
244         # Read one line. The data is in StreamReader's buffer
247         stream = asyncio.StreamReader(limit=3, loop=self.loop)
256         stream = asyncio.StreamReader(limit=3, loop=self.loop)
271         stream = asyncio.StreamReader(loop=self.loop)
289         stream = asyncio.StreamReader(limit=7, loop=self.loop)
303         stream = asyncio.StreamReader(limit=7, loop=self.loop)
316         stream = asyncio.StreamReader(limit=7, loop=self.loop)
335         stream = asyncio.StreamReader(loop=self.loop)
345         stream = asyncio.StreamReader(loop=self.loop)
353         stream = asyncio.StreamReader(loop=self.loop)
360         stream = asyncio.StreamReader(loop=self.loop)
371         stream = asyncio.StreamReader(loop=self.loop)
383         stream = asyncio.StreamReader(loop=self.loop)
388         stream = asyncio.StreamReader(loop=self.loop)
406         stream = asyncio.StreamReader(loop=self.loop)
441         stream = asyncio.StreamReader(loop=self.loop)
454         stream = asyncio.StreamReader(loop=self.loop, limit=3)
471         stream = asyncio.StreamReader(loop=self.loop)
484         stream = asyncio.StreamReader(loop=self.loop)
500         stream = asyncio.StreamReader(limit=3, loop=self.loop)
508         stream = asyncio.StreamReader(loop=self.loop)
526         stream = asyncio.StreamReader(loop=self.loop)
537         stream = asyncio.StreamReader(loop=self.loop)
545         stream = asyncio.StreamReader(loop=self.loop)
558         stream = asyncio.StreamReader(loop=self.loop)
776         # StreamReader's limit so that twice it is less than the size
790         reader = asyncio.StreamReader(loop=self.loop, limit=1)
814             asyncio.StreamReader()
820             return asyncio.StreamReader()
831         reader = asyncio.StreamReader()
922         stream = asyncio.StreamReader(loop=self.loop)
923         self.assertEqual("<StreamReader>", repr(stream))
926         stream = asyncio.StreamReader(loop=self.loop, limit=123)
927         self.assertEqual("<StreamReader limit=123>", repr(stream))
930         stream = asyncio.StreamReader(loop=self.loop)
932         self.assertEqual("<StreamReader eof>", repr(stream))
935         stream = asyncio.StreamReader(loop=self.loop)
937         self.assertEqual("<StreamReader 4 bytes>", repr(stream))
940         stream = asyncio.StreamReader(loop=self.loop)
943         self.assertEqual("<StreamReader exception=RuntimeError()>",
947         stream = asyncio.StreamReader(loop=self.loop)
951             r"<StreamReader waiter=<Future pending[\S ]*>>")
955         self.assertEqual("<StreamReader>", repr(stream))
958         stream = asyncio.StreamReader(loop=self.loop)
962         self.assertEqual("<StreamReader transport=<Transport>>", repr(stream))