-record(runtime, {
    boundary :: lightspeed@async@backpressure:boundary(),
    next_seq :: integer(),
    tasks_rev :: list(lightspeed@async@backpressure:task()),
    in_flight_count :: integer(),
    queued_count :: integer()
}).