def talk.read

bend-kit-http@0.38.2.0 · http.bend:6145

import Base
import bend-kit-http@0.38.2.0/admission.bend as Admission

6145def talk.read(+inbox: Chan(Admission.Command), held: Bool, +settings: Limits, sv: Sv, phase: Phase, m: Socket & Result<&1, &1, U32 & String, Unit>) -> IO((Socket & Turn) & Phase):
6146  (s, r) = m
6147  match r:
6148    case Fail{(code, message)}:
6149      IO.pure((Socket & Turn) & Phase, ((s, TurnInputFailed{SendContinue{}, code, message}), phase))
6150    case Done{u}:
6151      talk.read.loop(inbox, held, settings, ReadChecking{s, sv, phase})