def Manager.loops

bend-kube-runtime@0.2.0.0 · src/runtime.bend:704

import Base
import bend-kube-runtime@0.2.0.0/src/json.bend as J
import bend-kube-runtime@0.2.0.0/src/config.bend as K
import bend-kube-runtime@0.2.0.0/src/queue.bend as Q

704def Manager.loops(~rec: U32 -> J.Json -> K.Config -> IO(Q.Action), +cfg: K.Config, cs: List<&2, Ctrl>,
705  chs: List<&2, Chan(Msg)>, +status: Chan(SMsg), +i: U32) -> IO(Unit):
706  match cs chs:
707    case Con{Ctrl{p, l, os, m}, t} Con{ch, ct}:
708      IO.bind(Unit, Unit, IO.spawn(Unit, Ctl.loop(~rec, cfg, p, m, ch, status, i)),
709        u => Manager.loops(~rec, cfg, t, ct, status, (i + 1 : U32)))
710    case _ _:
711      IO.pure(Unit, Unit{})