Module `Dream_httpaf_.Client_connection`Source

Sourcemodule Reader = Parse.Reader

Sourcemodule Writer = Serialize.Writer

Sourcetype error = [

| `Malformed_response of string
| `Invalid_response_body_length of Response.t
| `Exn of exn

]

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

Sourcetype error_handler = error -> unit

Sourcetype t = {

config : Config.t;
reader : Reader.response;
writer : Writer.t;
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

Source

val 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

Source

val _next_read_operation : 
  t ->
  [> `Close | `Error of Reader.response_error | `Read | `Start | `Yield ]

Source

val _final_read_operation_for : 
  t ->
  Respd.t ->
  [> `Close | `Error of Reader.response_error | `Read | `Start | `Yield ]

Sourceval next_read_operation : t -> [> `Close | `Read | `Yield ]

Source

val 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

Source

val _next_write_operation : 
  t ->
  [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]

Source

val _final_write_operation_for : 
  t ->
  Respd.t ->
  [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]

Source

val 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

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-httpaf_/Dream_httpaf_/Client_connection/index.html

Module `Dream_httpaf_.Client_connection`Source

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-httpaf_/Dream_httpaf_/Client_connection/index.html

Module Dream_httpaf_.Client_connectionSource

Module `Dream_httpaf_.Client_connection`Source