import asyncio
import sys
import socket


async def connect_test( loop ):
    #reader = None
    #writer = None
    try:
        reader, writer = await asyncio.open_connection( host = '127.0.0.1', port = 3306, loop = loop )
        # uncomment next line to make it work
        #data = await reader.readexactly(4)
        writer.transport.pause_reading()
        writer.transport.resume_reading()
        data = await reader.readexactly(4)
        print(data)
    except Exception as e:
        print(e)
    finally:
        if( writer ):
            writer.close()


def main():
    loop = asyncio.get_event_loop()
    if sys.platform == 'win32':
        loop = asyncio.ProactorEventLoop()
        asyncio.set_event_loop( loop )

    loop.run_until_complete( connect_test( loop ) )
    loop.close()

if __name__ == '__main__':
    main()