def Watcher.merge

bend-kube-runtime@0.2.0.0 · src/watcher.bend:180

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

import Base

180# Feeds a run of inputs (the events of one recv), joining the outputs. A
181# step that asks to back off ends the run's effect on the stream: the
182# driver reconnects.
183def Watcher.merge(acc: Step, x: Input) -> Step:
184  match acc:
185    case Step{st, outs, w}:
186      Watcher.merge.go(outs, w, Watcher.step(st, x))

Uses (4)

Used by (2)