Advertisement
Guest User

Untitled

a guest
Feb 6th, 2016
64
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.69 KB | None | 0 0
  1. import asyncio
  2. import datetime
  3. import websockets
  4.  
  5.  
  6. async def clock(websocket):
  7. while True:
  8. now = datetime.datetime.utcnow().isoformat() + 'Z'
  9. await websocket.send(now)
  10. await asyncio.sleep(5)
  11.  
  12.  
  13. async def handler(websocket, path):
  14. while True:
  15. recv_task = asyncio.ensure_future(websocket.recv())
  16. done, pending = asyncio.wait([recv_task])
  17.  
  18. if recv_task in done:
  19. result = recv_task.result()
  20. print("result = {}".format(result))
  21. else:
  22. print("no result")
  23.  
  24.  
  25. start_server = websockets.serve(handler, 'localhost', 8088)
  26.  
  27. asyncio.get_event_loop().run_until_complete(start_server)
  28. asyncio.get_event_loop().run_forever()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement