(self)
| 735 | return app, srv, url, sock_path |
| 736 | |
| 737 | def test_tcp_connector(self): |
| 738 | @asyncio.coroutine |
| 739 | def handler(request): |
| 740 | return web.HTTPOk() |
| 741 | |
| 742 | app, srv, url = self.loop.run_until_complete( |
| 743 | self.create_server('get', '/', handler)) |
| 744 | conn = aiohttp.TCPConnector(loop=self.loop) |
| 745 | r = self.loop.run_until_complete( |
| 746 | aiohttp.request( |
| 747 | 'get', url, |
| 748 | connector=conn, |
| 749 | loop=self.loop)) |
| 750 | self.loop.run_until_complete(r.release()) |
| 751 | self.assertEqual(r.status, 200) |
| 752 | r.close() |
| 753 | conn.close() |
| 754 | |
| 755 | def test_tcp_connector_uses_provided_local_addr(self): |
| 756 | @asyncio.coroutine |
nothing calls this directly
no test coverage detected