websocket.py 文件源码

def run(self):
        self.logger = logging.getLogger("websocket")
        self.logger.info("Starting OverStream Websocket on Port {port}".format(port=self.PORT))

        print(self.plugin_engine.get_data())

        start_server = websockets.serve(self.websocket_connection, 'localhost', self.PORT)

        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)

        asyncio.get_event_loop().run_until_complete(start_server)
        asyncio.get_event_loop().run_forever()