syndicate-lang
/
syndicate-py
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Tighten

This commit is contained in:
Tony Garnock-Jones 2021-08-19 14:06:33 -04:00
parent 1f7832a358
commit 822d38dcf9
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
chat.py
View File

@ -42,15 +42,10 @@ def main_facet(turn, root_facet, ds):
async def accept_input():
reader = asyncio.StreamReader()
await actor.find_loop().connect_read_pipe(
lambda: asyncio.StreamReaderProtocol(reader),
sys.stdin)
while True:
line = (await reader.readline()).decode('utf-8')
if not line:
actor.Turn.external(f, lambda turn: turn.stop(root_facet))
break
await actor.find_loop().connect_read_pipe(lambda: asyncio.StreamReaderProtocol(reader), sys.stdin)
while line := (await reader.readline()).decode('utf-8'):
actor.Turn.external(f, lambda turn: turn.send(ds, Says(me, line.strip())))
actor.Turn.external(f, lambda turn: turn.stop(root_facet))
turn.linked_task(accept_input())
def main(turn):