Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import asyncio
- import datetime
- import websockets
- async def clock(websocket):
- while True:
- now = datetime.datetime.utcnow().isoformat() + 'Z'
- await websocket.send(now)
- await asyncio.sleep(5)
- async def handler(websocket, path):
- while True:
- recv_task = asyncio.ensure_future(websocket.recv())
- done, pending = asyncio.wait([recv_task])
- if recv_task in done:
- result = recv_task.result()
- print("result = {}".format(result))
- else:
- print("no result")
- start_server = websockets.serve(handler, 'localhost', 8088)
- asyncio.get_event_loop().run_until_complete(start_server)
- asyncio.get_event_loop().run_forever()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement