Module Dream_h2.RespdSource

Sourcemodule Writer = Serialize.Writer
Sourcetype error = [
  1. | `Malformed_response of string
  2. | `Invalid_response_body_length of Response.t
  3. | `Protocol_error of Error_code.t * string
  4. | `Exn of exn
]
Sourcetype error_handler = error -> unit
Sourcetype response_handler = Response.t -> Body.Reader.t -> unit
Sourcetype response_info = {
  1. response : Response.t;
  2. response_body : Body.Reader.t;
  3. mutable response_body_bytes : int64;
  4. mutable trailers_parser : Stream.partial_headers option;
}
Sourcetype trailers_handler = Headers.t -> unit
Sourcetype active_request = {
  1. request : Request.t;
  2. request_body : Body.Writer.t;
  3. response_handler : response_handler;
  4. trailers_handler : trailers_handler;
}
Sourceval response_body_exn : (((response_info, response_info Stream.remote_state) Stream.active_state, 'a, 'b) Stream.state, 'c, 'd) Stream.stream -> Body.Reader.t
Sourceval close_stream : ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream -> unit
Sourceval _report_error : t -> ?response_body:Body.Reader.t -> error -> Error_code.t -> bool
Sourceval report_error : t -> error -> Error_code.t -> unit
Sourceval requires_output : ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream -> bool
Sourceval flush_request_body : ((('a, 'a Stream.remote_state) Stream.active_state, active_request, 'b) Stream.state, 'c, 'd) Stream.stream -> max_bytes:int -> int
Sourceval deliver_trailer_headers : ((('a, 'b Stream.remote_state) Stream.active_state, active_request, 'c) Stream.state, 'd, 'e) Stream.stream -> Headers.t -> unit
Sourceval 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