def talk.read

bend-kit-http@0.38.5.0 · http.bend:6137

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

6137def 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):
6138  (s, r) = m
6139  match r:
6140    case Fail{(code, message)}:
6141      IO.pure((Socket & Turn) & Phase, ((s, TurnInputFailed{SendContinue{}, code, message}), phase))
6142    case Done{u}:
6143      talk.read.loop(inbox, held, settings, ReadChecking{s, sv, phase})