def Serve.listening

bend-kube-runtime@0.2.0.0 · src/serve.bend:226

import bend-kube-runtime@0.2.0.0/src/serve.bend as Serve
import Base
import bend-kube-runtime@0.2.0.0/src/runtime.bend as R

226def Serve.listening(r: Serve.Res(Listener), +status: Chan(R.SMsg)) -> IO(Unit):
227  match r:
228    case Done{l}:
229      IO.bind(Listener & Serve.Res(Socket), Unit, TCP.accept(l),
230        p => Serve.loop(4294967295n, AEv.got(p), status))
231    case Fail{(c, m)}:
232      IO.print_err("health server: " ++ m)

Uses (16)

Used by (1)