def tick.at

bend-kit-runner@0.13.0.1 · runner.bend:1619

import Base
import bend-kit-bytes@0.3.3.0/bytes.bend as Bytes
import bend-kit-resources@0.1.0.0/resources.bend as Res
import bend-kit-retry@0.3.0.0/retry.bend as Retry

1619# Fuel for each pending ticket, each attempt that may already run, and the last look at the inbox.
1620def tick.at(~A: Data, ~penc: A -> Bytes.Bytes, ~target: A -> String, ~work: A -> IO(Retry.Outcome), +now: Nat, r: Runner<A>) -> IO(Runner<A> & Out(Bool)):
1621  Runner{j, +s, +p, c, ib, fs} = r
1622  +fuel = Nat.add(2n, Nat.add(pending(A, s), Res.capacity(p)))
1623  do IO<Runner<A> & Out(Bool)>:
1624    k : Claimed(A) <- claim(~A, ~penc, ~target, ~work, fuel, now, Runner{j, s, p, c, ib, fs})
1625    tick.run(~A, ~penc, ~target, ~work, fuel, False{}, k)