def Ctl.on_msg

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

import Base
import bend-kube-runtime@0.2.0.0/src/queue.bend as Q

410# A message's effect on the state, and the timers it arms.
411def Ctl.on_msg(st: CState, m: Msg, +kind: String) -> CState & List<&2, Q.Timer>:
412  match m:
413    case MOuts{+src, outs}:
414      (Ctl.on_outs(st, src, outs, kind, U32.is_eq(src, 0)), Nil{})
415    case MDone{key, a}:
416      Ctl.on_done.st(st, key, a)
417    case MWake{key, g}:
418      Ctl.on_wake(st, key, g)