def serve.write.send.plan

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

import Base
import bend-kit-http@0.38.2.0/completion.bend as Completion
import bend-kit-time@0.3.0.0/time.bend as Time
import bend-kit-bytes@0.3.3.0/bytes.bend as Bytes

6960def serve.write.send.plan(
6961  ~S: Type, ~write: S -> Writer -> Completion.Receipt -> IO(Writer & Completion.Receipt), ~dispose: S -> IO(Unit),
6962  observer: Completion.Receipt, receipt: Completion.Receipt, +settings: Limits, s: Socket, rest: Bytes.Bytes,
6963  +keep: Bool, +head: Bool, +status: U32, state: S, plan: WriterMode & Map<&2, List<&2, String>>
6964) -> IO(Maybe<&1, Socket & Turn>):
6965  Limits{max, cap, hm, bm, im, wm} = settings
6966  (mode, headers) = plan
6967  sent_headers = writer.connection(keep, headers)
6968  do IO<Maybe<&1, Socket & Turn>>:
6969    now : Time.Duration <- Time.mono()
6970    +until : Time.Duration = Time.Duration.add(now, Time.Duration.of_ms(wm))
6971    sent : Socket & Result<&1, &1, U32 & String, Unit> <-
6972      bounded.send(s, Bytes.from_string(response(status, sent_headers, "")), until)
6973    serve.write.open(~S, ~write, ~dispose, observer, receipt, status, settings, keep, rest, state, mode,
6974      frame.nobody(status, head), until, sent)