Lines Matching defs:asyncio

18 import asyncio
23     asyncio.set_event_loop_policy(None)
32         self.loop = asyncio.new_event_loop()
59             conn_fut = asyncio.open_connection(*httpd.address)
65             conn_fut = asyncio.open_unix_connection(httpd.address)
74             asyncio.set_event_loop(None)
86             conn_fut = asyncio.open_connection(
96             conn_fut = asyncio.open_unix_connection(
118             conn_fut = asyncio.open_connection(*httpd.address)
124             conn_fut = asyncio.open_unix_connection(httpd.address)
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)
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)
446         with self.assertRaisesRegex(asyncio.IncompleteReadError,
454         stream = asyncio.StreamReader(loop=self.loop, limit=3)
456         with self.assertRaisesRegex(asyncio.LimitOverrunError,
463         with self.assertRaisesRegex(asyncio.LimitOverrunError,
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)
517         with self.assertRaises(asyncio.IncompleteReadError) as cm:
526         stream = asyncio.StreamReader(loop=self.loop)
537         stream = asyncio.StreamReader(loop=self.loop)
545         stream = asyncio.StreamReader(loop=self.loop)
553         self.loop.run_until_complete(asyncio.wait([t1, t2]))
558         stream = asyncio.StreamReader(loop=self.loop)
587                     asyncio.start_server(self.handle_client,
600                     asyncio.start_server(self.handle_client_callback,
611             reader, writer = await asyncio.open_connection(*addr)
658                     asyncio.start_unix_server(self.handle_client,
666                 start = asyncio.start_unix_server(self.handle_client_callback,
677             reader, writer = await asyncio.open_unix_connection(path)
735                     asyncio.start_server(self.handle_client,
746             reader, writer = await asyncio.open_connection(*addr)
774         # See asyncio issue 168.  This test is derived from the example
790         reader = asyncio.StreamReader(loop=self.loop, limit=1)
791         protocol = asyncio.StreamReaderProtocol(reader, loop=self.loop)
795         watcher = asyncio.SafeChildWatcher()
798             asyncio.set_child_watcher(watcher)
799             create = asyncio.create_subprocess_exec(
806             asyncio.set_child_watcher(None)
814             asyncio.StreamReader()
817         # asyncio issue #184: Ensure that StreamReaderProtocol constructor
820             return asyncio.StreamReader()
826         # asyncio issue #184: Ensure that StreamReaderProtocol constructor
829         self.addCleanup(asyncio.set_event_loop, None)
830         asyncio.set_event_loop(self.loop)
831         reader = asyncio.StreamReader()
838             asyncio.StreamReaderProtocol(reader)
841         # asyncio issue #184: Ensure that StreamReaderProtocol constructor
845             return asyncio.StreamReaderProtocol(reader)
850         # asyncio issue #184: Ensure that StreamReaderProtocol constructor
853         self.addCleanup(asyncio.set_event_loop, None)
854         asyncio.set_event_loop(self.loop)
856         protocol = asyncio.StreamReaderProtocol(reader)
869             loop = asyncio.get_running_loop()
870             stream = asyncio.streams.FlowControlMixin(loop)
873             await asyncio.gather(*[drainer(stream) for _ in range(10)])
881         # This test should not use asyncio for the mock server; the
899             reader, writer = await asyncio.open_connection(host, port)
922         stream = asyncio.StreamReader(loop=self.loop)
926         stream = asyncio.StreamReader(loop=self.loop, limit=123)
930         stream = asyncio.StreamReader(loop=self.loop)
935         stream = asyncio.StreamReader(loop=self.loop)
940         stream = asyncio.StreamReader(loop=self.loop)
947         stream = asyncio.StreamReader(loop=self.loop)
948         stream._waiter = asyncio.Future(loop=self.loop)
958         stream = asyncio.StreamReader(loop=self.loop)
965         e = asyncio.IncompleteReadError(b'abc', 10)
974         e = asyncio.LimitOverrunError('message', 10)
984                 asyncio.open_connection(*httpd.address))
1001                 asyncio.open_connection(*httpd.address))
1012             rd, wr = await asyncio.open_connection(*httpd.address)
1032             rd, wr = await asyncio.open_connection(*httpd.address)
1059                     asyncio.open_connection(*httpd.address))