Watcher.Watcher.merge: def of bend-kube-runtime@0.2.0.0
Import: import bend-kube-runtime@0.2.0.0/src/watcher.bend as Watcher
Lines 180-186 of bend-kube-runtime@0.2.0.0/src/watcher.bend: https://jend.leeeet.dev/read.txt?path=bend-kube-runtime@0.2.0.0/src/watcher.bend&start_line=180&end_line=186

import Base

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

Uses (4):
  https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/watcher.bend&name=Input
  https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/watcher.bend&name=Step
  https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/watcher.bend&name=Watcher.merge.go
  https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/watcher.bend&name=Watcher.step