jonpovey

async with join_any() as tm:
  @tm.fork
  async def block1() -> None:
    ...
  tm.add("test", Combine(...))
# join_any here

await tm.join_all()  # wait for them all to finish now

jonpovey

HIT_HMD2043

                               __    __
                                ||  ||
                                ||==|| I T
                               _||  ||_

                    Harold Innovation Technologies
                "If it ain't a HIT, it's a piece of..."