especificos-node/client/websocket.py

import asyncio
import websockets
import threading

class Websocket(threading.Thread):
    def __init__(self):
        super(Websocket, self).__init__()
        self.start_server = websockets.serve(self.handle_input, '127.0.0.1', 5678)
        #asyncio.get_event_loop().run_until_complete(start_server)
        #asyncio.get_event_loop().run_forever()
        self.loop = asyncio.get_event_loop()

    def run(self):
        asyncio.set_event_loop(self.loop)
        self.loop.run_until_complete(self.start_server)
        self.loop.run_forever()
        print("finitO?")
    async def handle_input(self,websocket, path):
        while True:
            try:
                data = await websocket.recv()
                print("{}".format(data))
            except websockets.exceptions.ConnectionClosed as c:
                print( "client dc'd")
                break