def Drv.send_all

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

import Base
import bend-kube-runtime@0.2.0.0/src/watcher.bend as W

167# Hands the outputs to every subscriber (a shared watch fans out).
168def Drv.send_all(subs: List<&2, Sub>, +outs: List<&2, W.Out>) -> IO(Unit):
169  match subs:
170    case Nil{}:
171      IO.pure(Unit, Unit{})
172    case Con{Sub{ch, src}, t}:
173      IO.bind(Unit, Unit, Drv.send(ch, src, outs), u => Drv.send_all(t, outs))