Add back in async gen loop

sigintsaviour_ci_worked
Tyler Goodlet 2022-02-16 13:59:23 -05:00
parent df16a0c315
commit 67607a4d37
1 changed files with 8 additions and 9 deletions

View File

@ -6,6 +6,7 @@ async def gen():
yield 'yo'
await tractor.breakpoint()
yield 'yo'
await tractor.breakpoint()
@tractor.context
@ -13,14 +14,17 @@ async def just_bp(
ctx: tractor.Context,
) -> None:
await ctx.started('yo bpin here')
await ctx.started()
await tractor.breakpoint()
# TODO: bps and errors in this call..
# async for val in gen():
# print(val)
async for val in gen():
print(val)
await trio.sleep(0.5)
# await trio.sleep(0.5)
# prematurely destroy the connection
await ctx.chan.aclose()
# THIS CAUSES AN UNRECOVERABLE HANG
# without latest ``pdbpp``:
@ -30,20 +34,15 @@ async def just_bp(
async def main():
async with tractor.open_nursery(
# loglevel='transport',
debug_mode=True,
) as n:
p = await n.start_actor(
'bp_boi',
enable_modules=[__name__],
# debug_mode=True,
)
async with p.open_context(
just_bp,
) as (ctx, first):
# await tractor.breakpoint()
# breakpoint()
await trio.sleep_forever()