#!/usr/bin/env python import asyncio import websockets async def echo(websocket, path): async for message in websocket: print(message) await websocket.send(message) asyncio.get_event_loop().run_until_complete( websockets.serve(echo, 'localhost', 5678)) asyncio.get_event_loop().run_forever()