def Exec.opened

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

import Base
import bend-kube-runtime@0.2.0.0/src/net.bend as N
import bend-kube-runtime@0.2.0.0/src/client.bend as Cl

367def Exec.opened(t: Result<&1, &1, U32 & String, N.Tls>, stdin: Maybe<&2, String>, +k: U32,
368  +ms: U32) -> IO(Result<&2, &2, Cl.KErr, Out>):
369  match t:
370    case Done{N.Tls{s}}:
371      IO.bind(Socket & Result<&2, &2, Cl.KErr, Scan>, Result<&2, &2, Cl.KErr, Out>,
372        Exec.head(4096n, HChk{s, False{}, False{}}, Scan{Nil{}, 0, Nil{}, False{}}, ms),
373        p => Exec.headed(p, stdin, k, ms))
374    case Fail{(c, m)}:
375      IO.pure(Result<&2, &2, Cl.KErr, Out>, Fail{Cl.KNet{c, m}})