aboutsummaryrefslogtreecommitdiff
path: root/backend/microservice/api/ml_socket.py
diff options
context:
space:
mode:
authorNevena Bojovic <nenabojov@gmail.com>2022-04-13 21:44:32 +0200
committerNevena Bojovic <nenabojov@gmail.com>2022-04-13 21:44:32 +0200
commit8568f5eadf09ff9536aa19054a129ab4aec49991 (patch)
treed0ef5278d5c763e5325b9af88401d01489959dff /backend/microservice/api/ml_socket.py
parentea53b083e0513ddcd1faa1a6de9c89c9671e4eb3 (diff)
Doradjen training zahtev.
Diffstat (limited to 'backend/microservice/api/ml_socket.py')
-rw-r--r--backend/microservice/api/ml_socket.py30
1 files changed, 0 insertions, 30 deletions
diff --git a/backend/microservice/api/ml_socket.py b/backend/microservice/api/ml_socket.py
deleted file mode 100644
index cab157eb..00000000
--- a/backend/microservice/api/ml_socket.py
+++ /dev/null
@@ -1,30 +0,0 @@
-import asyncio
-import websockets
-import json
-
-def get_or_create_eventloop():
- try:
- return asyncio.get_event_loop()
- except RuntimeError as ex:
- if "There is no current event loop in thread" in str(ex):
- loop = asyncio.new_event_loop()
- asyncio.set_event_loop(loop)
- return asyncio.get_event_loop()
-
-# create handler for each connection
-async def handler(websocket, path):
- #data = json.loads(await websocket.recv())
- #print(data['test'])
- msg = await websocket.recv()
- print(msg)
-
-async def start():
- start_server = websockets.serve(handler, "localhost", 5027)
- print('Websocket starting...')
- get_or_create_eventloop().run_until_complete(start_server)
- get_or_create_eventloop().run_forever()
-
-async def send(msg):
- print("WS sending message:")
- print(msg)
- await websocket.send(msg) \ No newline at end of file