def settle.flight

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

import Base
import bend-kit-bytes@0.3.3.0/bytes.bend as Bytes
import bend-kit-scheduler@0.4.1.0/queue.bend as Q
import bend-kit-retry@0.3.0.0/retry.bend as Retry

1341def settle.flight(~A: Data, ~penc: A -> Bytes.Bytes, mf: Maybe<&1, Flight<A>>, +o: Retry.Outcome, +now: Nat, +rnd: Nat, r: Runner<A>, err: Out(Unit),
1342    next: Runner<A> -> Out(Unit) -> IO(Runner<A> & Out(Bool))) -> IO(Runner<A> & Out(Bool)):
1343  match mf:
1344    case None{}:
1345      next(r, err)
1346    case Some{Flight{Q.Ticket{id, d, x}, g, b, key}}:
1347      settle.op(~A, ~penc, o, b, id, key, now, rnd, r, g, err, next)