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

Lines Matching defs:asyncio
1 import asyncio
2 import asyncio.sslproto
29     asyncio.set_event_loop_policy(None)
32 class MyBaseProto(asyncio.Protocol):
41             self.connected = asyncio.Future(loop=loop)
42             self.done = asyncio.Future(loop=loop)
84         self.loop = asyncio.new_event_loop()
165         # TODO This warning has to be fixed in asyncio.
166         logger = logging.getLogger('asyncio')
181         return asyncio.new_event_loop()
184         return asyncio.DefaultEventLoopPolicy()
187         if not isinstance(obj, asyncio.StreamWriter):
226             fut = asyncio.Future()
258             srv = await asyncio.start_server(
275                 await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
323             reader, writer = await asyncio.open_connection(
344             reader, writer = await asyncio.open_connection(
368                 return await asyncio.gather(*tasks)
402             reader, writer = await asyncio.open_connection(
442             reader, writer = await asyncio.open_connection(
478             await asyncio.wait_for(
480                     asyncio.Protocol,
491             with self.assertRaises(asyncio.TimeoutError):
517         class ClientProto(asyncio.Protocol):
630         self.loop.run_until_complete(asyncio.sleep(0.1))
654             reader, writer = await asyncio.open_connection(
699         class ClientProto(asyncio.Protocol):
717             await asyncio.sleep(0.5)
736                 asyncio.wait_for(client(srv.addr),
758         class ClientProto(asyncio.Protocol):
778             await asyncio.sleep(0.5)
795                 asyncio.wait_for(client(srv.addr),
830         class ClientProtoFirst(asyncio.BufferedProtocol):
849         class ClientProtoSecond(asyncio.Protocol):
866             await asyncio.sleep(0.5)
895                 asyncio.wait_for(client(srv.addr),
919         class ClientProto(asyncio.Protocol):
937             await asyncio.sleep(0.5)
949             with self.assertRaises(asyncio.TimeoutError):
950                 await asyncio.wait_for(
956                 asyncio.wait_for(client(srv.addr),
978         class ServerProto(asyncio.Protocol):
1028                 await asyncio.wait_for(
1070         class ServerProtocol(asyncio.StreamReaderProtocol):
1087             reader = asyncio.StreamReader()
1092             fut = asyncio.Future()
1168                 await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
1209             reader, writer = await asyncio.open_connection(
1231                 return await asyncio.gather(*tasks)
1280             reader, writer = await asyncio.open_connection(
1392             reader, writer = await asyncio.open_connection(
1438                 await asyncio.wait_for(
1439                     self.loop.create_connection(asyncio.Protocol,
1442             except (ConnectionRefusedError, asyncio.TimeoutError):
1467                 await asyncio.wait_for(
1468                     self.loop.create_connection(asyncio.Protocol, *addr,
1471             except (ConnectionRefusedError, asyncio.TimeoutError):
1496         class Protocol(asyncio.Protocol):
1498                 self.fut = asyncio.Future(loop=loop)
1513         # asyncio has no shutdown timeout, but it ends up with a circular
1525         eof = asyncio.Event()
1544         class Protocol(asyncio.Protocol):
1546                 self.fut = asyncio.Future(loop=loop)