def admission.write

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

import Base
import bend-kit-http@0.38.2.0/admission.bend as Admission
import bend-kit-http@0.38.2.0/completion.bend as Completion
import bend-kit-bytes@0.3.3.0/bytes.bend as Bytes

6986def admission.write(
6987  ~S: Type, ~start: Req -> IO(WriteHead<S>), ~write: S -> Writer -> Completion.Receipt -> IO(Writer & Completion.Receipt), ~dispose: S -> IO(Unit), ~observe: U32 -> Completion.Outcome -> IO(Unit),
6988  admitted: Bool, +inbox: Chan(Admission.Command), +settings: Limits,
6989  s: Socket, req: Req, rest: Bytes.Bytes, v11: Bool
6990) -> IO(Maybe<&1, Socket & Turn>):
6991  match admitted:
6992    case False{}:
6993      Limits{max, cap, hm, bm, im, wm} = settings
6994      do IO<Maybe<&1, Socket & Turn>>:
6995        admission.reject(Completion.Observed{status => outcome => observe(status, outcome)}, s, admission.head(req), wm)
6996        return None{}
6997    case True{}:
6998      Req{+method, path, +headers, body} = req
6999      do IO<Maybe<&1, Socket & Turn>>:
7000        out : WriteHead<S> <- start(Req{method, path, headers, body})
7001        after : Maybe<&1, Socket & Turn> <- serve.write.send(~S, ~write, ~dispose, Completion.Observed{status => outcome => observe(status, outcome)}, settings, s, rest, headers, v11, String.eq(method, "HEAD"), out)
7002        Admission.give(inbox, 1)
7003        return after
7004
7005@unsafe