def talk

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

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

6230def talk(~C: Data, ~h: C -> Req -> IO(Reply), ~observe: C -> U32 -> Completion.Outcome -> IO(Unit), +context: C, +settings: Limits, +inbox: Chan(Admission.Command), st: Maybe<&1, Serving>) -> IO(Unit):
6231  Limits{max, cap, hm, bm, im, wm} = settings
6232  match st:
6233    case None{}:
6234      IO.pure(Unit, Unit{})
6235    case Some{Serving{(s, t), phase}}:
6236      match t:
6237        case TurnMore{sv, cont}:
6238          do IO<Unit>:
6239            received : (Socket & Turn) & Phase <- talk.recv(inbox, False{}, settings, s, sv, cont, phase)
6240            talk(~C, ~h, ~observe, context, settings, inbox, Some{talk.state(received)})
6241        case TurnReq{req, rest, v11}:
6242          do IO<Unit>:
6243            admitted : Bool <- Admission.take(inbox, 1)
6244            next : Maybe<&1, Socket & Turn> <- admission.request(~C, ~h, ~observe, admitted, inbox, context, settings, s, req, rest, v11)
6245            talk(~C, ~h, ~observe, context, settings, inbox, serve.write.state(next))
6246        case TurnFail{status}:
6247          reply_fail(Completion.Observed{status => outcome => observe(context, status, outcome)}, s, status, wm)
6248        case TurnClose{}:
6249          Socket.close(s)
6250        case TurnInputFailed{operation, code, message}:
6251          Socket.close(s)