responder with websocket

client.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import asyncio
import websockets

async def client():
    async with websockets.connect('ws://127.0.0.1:5042/ws') as websocket:
        await websocket.send("KOBAYASHI")
        response = await websocket.recv()
        print(response)

asyncio.get_event_loop().run_until_complete(client())

server.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import time
import responder

api = responder.API()

@api.route('/ws', websocket=True)
async def websocket(ws):

    def sleep(name, s=5):
        time.sleep(s)
        return "Hello {}".format(name)

    await ws.accept()
    while True:
        name = await ws.receive_text()
        re = sleep(name)
        await ws.send_text(re)
    await ws.close()

if __name__ == '__main__':
    api.run()