def server.read.done

emerging-ezhttp@0.21.0.0 · src/server.bend:74

import Base
import emerging-ezhttp@0.21.0.0/src/http.bend as Http
import emerging-ezhttp@0.21.0.0/src/step.bend as Step
import emerging-ezhttp@0.21.0.0/src/wirespec.bend as Spec

74# the request once it has all arrived (or the peer closed, or the receives
75# ran out): its pieces put together and parsed
76def server.read.done(sock: Socket, ps: List<&2, String>)
77  -> IO(Socket & Step.Got<Http.Request>):
78  IO.pure(Socket & Step.Got<Http.Request>,
79    (sock, Step.Kept{Http.ask(Spec.wire.join(ps))}))