import asyncio import warnings warnings.simplefilter("always", ResourceWarning) @asyncio.coroutine def run(loop): try: coro = loop.create_connection(asyncio.Protocol, '10.255.255.1', 80) # coro = loop.create_connection(asyncio.Protocol, 'www.google.com', 80) tr, pr = yield from asyncio.wait_for(coro, timeout=2) except asyncio.TimeoutError: print("Timed out...") else: print("Connected OK...") finally: if 'tr' in locals(): tr.close() loop = asyncio.get_event_loop() loop.run_until_complete(run(loop)) loop.close()