goodboy
/
tractor
1
0
Fork 1
Code Issues 1 Pull Requests 4 Packages Projects Releases Wiki Activity

Enable bp on clustering test

stricter_context_starting
Tyler Goodlet 2021-12-05 20:02:55 -05:00
parent 41a3e6a9ca
commit f3432bd8fb
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/test_clustering.py
View File

@ -14,7 +14,7 @@ MESSAGE = 'tractoring at full speed'
@tractor.context @tractor.context
async def worker(ctx: tractor.Context) -> None: async def worker(ctx: tractor.Context) -> None:
await ctx.started() await ctx.started()
async with ctx.open_stream() as stream: async with ctx.open_stream(backpressure=True) as stream:
async for msg in stream: async for msg in stream:
# do something with msg # do something with msg
print(msg) print(msg)