|
|
@@ -28,10 +28,13 @@ class Websocket(threading.Thread):
|
|
|
self.loop.run_until_complete(self.start_server)
|
|
|
self.loop.run_forever()
|
|
|
print("finitO?")
|
|
|
- async def handle_input(self,websocket, path):
|
|
|
+
|
|
|
+ @asyncio.coroutine
|
|
|
+ def handle_input(self,websocket, path):
|
|
|
while True:
|
|
|
try:
|
|
|
- data = await websocket.recv()
|
|
|
+ #data = await websocket.recv()
|
|
|
+ data = yield from websocket.recv()
|
|
|
try:
|
|
|
data=json.loads(data)
|
|
|
except Exception as e:
|