raw.py

import asyncio
import uvloop
from aiohttp import ClientSession

asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())


msg = b'\x10application/json{"processor": "", "op": "eval", "args": {"aliases": {}, "gremlin": "x + x", "bindings": {"x": 1}}, "requestId": "2f52dced-0c4d-4ccd-a8a6-62a59bbb52af"}'


async def test():
    session = ClientSession()
    ws = await session.ws_connect('ws://localhost:8182/gremlin')
    for x in range(1200):
        ws.send_bytes(msg)
    await receive(ws)
    await session.close()

async def receive(ws):
    for x in range(1200):
        resp = await ws.receive()
        # print(resp)
    await ws.close()


def go():
    loop = asyncio.get_event_loop()
    loop.run_until_complete(test())