def Keeper.start

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

import bend-kube-runtime@0.2.0.0/src/runtime.bend as Runtime

import Base

600# Starts a status keeper; answers its inbox.
601def Keeper.start() -> IO(Chan(SMsg)):
602  IO.bind(Chan(SMsg), Chan(SMsg), Chan.new(SMsg, 4096),
603    +c => IO.bind(Unit, Chan(SMsg), IO.spawn(Unit,
604      IO.bind(Maybe<&1, SMsg>, Unit, Chan.recv(SMsg, c),
605        x => Keeper.run(4294967295n, x, Map.new(&2, Snap), c))), u => IO.pure(Chan(SMsg), c)))

Uses (13)

Used by (2)