Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- IP = ''
- PORT = 8880
- import asyncio
- import multiprocessing
- import ssl
- async def start_client(loop):
- reader, writer = await asyncio.open_connection(IP, PORT, loop=loop)
- writer.write("Gimme gimme gimme".encode())
- writer.close()
- data = await reader.read()
- print(data.decode())
- loop = asyncio.get_event_loop()
- loop.run_until_complete(start_client(loop))
- loop.close()
- import asyncio
- import requests
- import json
- async def handle_echo(reader, writer):
- data = await reader.read()
- response = await whatsup()
- print(response)
- writer.write(response.encode())
- writer.write_eof()
- await writer.drain()
- writer.close()
- async def whatsup():
- return "Hello there!"
- loop = asyncio.get_event_loop()
- server = asyncio.start_server(handle_echo,
- IP,
- PORT,
- loop=loop)
- server = loop.run_until_complete(server)
- try:
- loop.run_forever()
- except:
- pass
- server.close()
- loop.run_until_complete(server.wait_closed())
- loop.close()
- while not reader.at_eof():
- data = await reader.read(100)
- print(data.decode())
Add Comment
Please, Sign In to add comment