forked from goodboy/tractor
1
0
Fork 0

Modernize streaming tests

bi_streaming
Tyler Goodlet 2021-06-13 20:26:41 -04:00
parent 43ce533dbf
commit 197d291ba8
1 changed files with 5 additions and 2 deletions

View File

@ -32,13 +32,16 @@ async def async_gen_stream(sequence):
# block indefinitely waiting to be cancelled by ``aclose()`` call
with trio.CancelScope() as cs:
await trio.sleep(float('inf'))
await trio.sleep_forever()
assert 0
assert cs.cancelled_caught
@tractor.stream
async def context_stream(ctx, sequence):
async def context_stream(
ctx: tractor.Context,
sequence
):
for i in sequence:
await ctx.send_yield(i)
await trio.sleep(0.1)