Guest User

Untitled

a guest
Nov 24th, 2017
76
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.07 KB | None | 0 0
  1. IP = ''
  2. PORT = 8880
  3.  
  4. import asyncio
  5. import multiprocessing
  6. import ssl
  7.  
  8. async def start_client(loop):
  9. reader, writer = await asyncio.open_connection(IP, PORT, loop=loop)
  10. writer.write("Gimme gimme gimme".encode())
  11. writer.close()
  12. data = await reader.read()
  13. print(data.decode())
  14.  
  15. loop = asyncio.get_event_loop()
  16. loop.run_until_complete(start_client(loop))
  17. loop.close()
  18.  
  19. import asyncio
  20. import requests
  21. import json
  22.  
  23. async def handle_echo(reader, writer):
  24. data = await reader.read()
  25. response = await whatsup()
  26. print(response)
  27. writer.write(response.encode())
  28. writer.write_eof()
  29. await writer.drain()
  30. writer.close()
  31.  
  32. async def whatsup():
  33. return "Hello there!"
  34.  
  35. loop = asyncio.get_event_loop()
  36. server = asyncio.start_server(handle_echo,
  37. IP,
  38. PORT,
  39. loop=loop)
  40. server = loop.run_until_complete(server)
  41.  
  42. try:
  43. loop.run_forever()
  44. except:
  45. pass
  46.  
  47. server.close()
  48. loop.run_until_complete(server.wait_closed())
  49. loop.close()
  50.  
  51. while not reader.at_eof():
  52. data = await reader.read(100)
  53. print(data.decode())
Add Comment
Please, Sign In to add comment