def Exec.listen

bend-kube-runtime@0.2.0.0 · src/exec.bend:300

import Base
import bend-kube-runtime@0.2.0.0/src/client.bend as Cl
import bend-kube-runtime@0.2.0.0/src/ws.bend as W

300def Exec.listen(s: Socket, rest: List<&2, U32>, +ms: U32) ->
301  IO(Result<&2, &2, Cl.KErr, Out>):
302  IO.bind(Socket & Result<&2, &2, Cl.KErr, Out>, Result<&2, &2, Cl.KErr, Out>,
303    Exec.read(4294967295n, XChk{s, False{}, False{}, None{}},
304      Acc.feed(Acc{W.WHead{}, Nil{}, Nil{}, Nil{}, 1, False{}}, rest), ms),
305    Exec.close)