Module Dream_httpaf_.Client_connectionSource

Sourcemodule Reader = Parse.Reader
Sourcemodule Writer = Serialize.Writer
Sourcetype error = [
  1. | `Malformed_response of string
  2. | `Invalid_response_body_length of Response.t
  3. | `Exn of exn
]
Sourcetype response_handler = Response.t -> Body.Reader.t -> unit
Sourcetype error_handler = error -> unit
Sourcetype t = {
  1. config : Config.t;
  2. reader : Reader.response;
  3. writer : Writer.t;
  4. request_queue : Respd.t Queue.t;
}
Sourceval is_closed : t -> bool
Sourceval is_waiting : t -> bool
Sourceval is_active : t -> bool
Sourceval current_respd_exn : t -> Respd.t
Sourceval yield_reader : t -> (unit -> unit) -> unit
Sourceval wakeup_reader : t -> unit
Sourceval yield_writer : t -> (unit -> unit) -> unit
Sourceval wakeup_writer : t -> unit
Sourceval create : ?config:Config.t -> unit -> t
Sourceval create_request_body : request:Request.t -> t -> Body.Writer.t
Sourceval request : t -> ?flush_headers_immediately:bool -> Request.t -> error_handler:(Respd.error -> unit) -> response_handler:(Response.t -> Body.Reader.t -> unit) -> Body.Writer.t
Sourceval shutdown_reader : t -> unit
Sourceval shutdown_writer : t -> unit
Sourceval shutdown : t -> unit
Sourceval set_error_and_handle : t -> Respd.error -> unit
Sourceval unexpected_eof : t -> unit
Sourceval report_exn : t -> exn -> unit
Sourceexception Local
Sourceval maybe_pipeline_queued_requests : t -> unit
Sourceval advance_request_queue : t -> unit
Sourceval _next_read_operation : t -> [> `Close | `Error of Reader.response_error | `Read | `Start | `Yield ]
Sourceval _final_read_operation_for : t -> Respd.t -> [> `Close | `Error of Reader.response_error | `Read | `Start | `Yield ]
Sourceval next_read_operation : t -> [> `Close | `Read | `Yield ]
Sourceval read_with_more : t -> Bigstringaf.t -> off:int -> len:int -> Reader.AU.more -> int
Sourceval read : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval read_eof : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval _next_write_operation : t -> [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]
Sourceval _final_write_operation_for : t -> Respd.t -> [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]
Sourceval next_write_operation : t -> [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]
Sourceval report_write_result : t -> [< `Closed | `Ok of int ] -> unit