Module `Dream_h2.Respd`Source

Sourcemodule Writer = Serialize.Writer

Sourcetype error = [

| `Malformed_response of string
| `Invalid_response_body_length of Response.t
| `Protocol_error of Error_code.t * string
| `Exn of exn

]

Sourcetype error_handler = error -> unit

Sourcetype response_handler = Response.t -> Body.Reader.t -> unit

Sourcetype response_info = {

response : Response.t;
response_body : Body.Reader.t;
mutable response_body_bytes : int64;
mutable trailers_parser : Stream.partial_headers option;

}

Sourcetype trailers_handler = Headers.t -> unit

Sourcetype active_request = {

request : Request.t;
request_body : Body.Writer.t;
response_handler : response_handler;
trailers_handler : trailers_handler;

}

Source

type active_state =
  (response_info, response_info Stream.remote_state) Stream.active_state

Source

type state =
  (active_state, active_request, active_request Stream.remote_state)
    Stream.state

Sourcetype t = (state, error, error_handler) Stream.stream

Source

val create_active_response : 
  Response.t ->
  Body.Reader.t ->
  response_info Stream.remote_state

Source

val response_body_exn : 
  (((response_info, response_info Stream.remote_state) Stream.active_state,
     'a,
     'b)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  Body.Reader.t

Source

val close_stream : 
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream ->
  unit

Source

val _report_error : 
  t ->
  ?response_body:Body.Reader.t ->
  error ->
  Error_code.t ->
  bool

Sourceval report_error : t -> error -> Error_code.t -> unit

Source

val requires_output : 
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream ->
  bool

Source

val flush_request_body : 
  ((('a, 'a Stream.remote_state) Stream.active_state, active_request, 'b)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  max_bytes:int ->
  int

Source

val deliver_trailer_headers : 
  ((('a, 'b Stream.remote_state) Stream.active_state, active_request, 'c)
     Stream.state,
    'd,
    'e)
    Stream.stream ->
  Headers.t ->
  unit

Source

val flush_response_body : 
  (((response_info, response_info Stream.remote_state) Stream.active_state,
     active_request,
     active_request Stream.remote_state)
     Stream.state,
    error,
    error_handler)
    Stream.stream ->
  unit

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Respd/index.html

Module `Dream_h2.Respd`Source

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Respd/index.html

Module Dream_h2.RespdSource

Module `Dream_h2.Respd`Source