import asyncio import websockets Clients =[] @asyncio.coroutine def onconnect(websocket, uri): Clients.append(websocket) while True: datain = yield from websocket.recv() msg = datain.split(",") print("From %s: %s" % (msg[0],msg[1])) dataout = "%s says: %s" % (msg[0],msg[1]) for client in Clients: if client == websocket: pass else: yield from client.send(dataout) start_server = websockets.serve(onconnect, 'localhost', 8002) asyncio.get_event_loop().run_until_complete(start_server) asyncio.get_event_loop().run_forever()