actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2025-01-22 22:05:57 +01:00
Code Issues Releases Wiki Activity

fix minor issues

Browse Source
This commit is contained in:
bott 2018-08-28 14:11:58 +02:00
parent 5d3c5056ed
commit 86c89dabcb
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
websocket-tcp-chat/client.py
View File

@ -10,7 +10,7 @@ import aiohttp
queue = asyncio.Queue() queue = asyncio.Queue()
async def start_client(url): async def start_client(url, loop):
name = input('Please enter your name: ') name = input('Please enter your name: ')
ws = await aiohttp.ClientSession().ws_connect(url, autoclose=False, autoping=False) ws = await aiohttp.ClientSession().ws_connect(url, autoclose=False, autoping=False)
@ -49,12 +49,12 @@ async def start_client(url):
async def tick(): async def tick():
while 1: while True:
await (await queue.get()) await (await queue.get())
async def main(url): async def main(url, loop):
await asyncio.wait([start_client(url), tick()]) await asyncio.wait([start_client(url, loop), tick()])
ARGS = argparse.ArgumentParser( ARGS = argparse.ArgumentParser(
@ -76,5 +76,5 @@ if __name__ == '__main__':
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
loop.add_signal_handler(signal.SIGINT, loop.stop) loop.add_signal_handler(signal.SIGINT, loop.stop)
asyncio.Task(main(url)) asyncio.Task(main(url, loop))
loop.run_forever() loop.run_forever()