mirror of https://github.com/nocturn9x/giambio.git
Updated the echo server to the new version of giambio
This commit is contained in:
parent
1eec3d3078
commit
cac4e50b84
11
test.py
11
test.py
|
@ -17,10 +17,11 @@ async def make_srv(address: tuple):
|
||||||
sock.listen(5)
|
sock.listen(5)
|
||||||
asock = loop.wrap_socket(sock)
|
asock = loop.wrap_socket(sock)
|
||||||
logging.info(f"Echo server serving asynchronously at {address}")
|
logging.info(f"Echo server serving asynchronously at {address}")
|
||||||
while True:
|
async with giambio.TaskManager(loop) as manager:
|
||||||
conn, addr = await asock.accept()
|
while True:
|
||||||
logging.info(f"{addr} connected")
|
conn, addr = await asock.accept()
|
||||||
task = loop.spawn(echo_server(conn, addr))
|
logging.info(f"{addr} connected")
|
||||||
|
task = manager.spawn(echo_server(conn, addr))
|
||||||
|
|
||||||
|
|
||||||
async def echo_server(sock: AsyncSocket, addr: tuple):
|
async def echo_server(sock: AsyncSocket, addr: tuple):
|
||||||
|
@ -41,4 +42,4 @@ async def echo_server(sock: AsyncSocket, addr: tuple):
|
||||||
try:
|
try:
|
||||||
loop.start(make_srv, ('', 1501))
|
loop.start(make_srv, ('', 1501))
|
||||||
except KeyboardInterrupt: # Exceptions propagate!
|
except KeyboardInterrupt: # Exceptions propagate!
|
||||||
pass
|
print("Exiting...")
|
||||||
|
|
Loading…
Reference in New Issue