Client_connection (u.49aedcbf71d42d7068f34cf1fd80a721.dream-httpaf.1.0.0~alpha3.doc.dream-httpaf.dream-h2.Dream_h2.Client

Sourcemodule Httpaf = Dream_httpaf_.Httpaf

Sourcemodule Hpack = Dream_hpack.Hpack

Sourcemodule AB = Angstrom.Buffered

Sourcemodule Reader = Parse.Reader

Sourcemodule Writer = Serialize.Writer

Sourcemodule StreamsTbl = Scheduler.StreamsTbl

Sourcemodule Scheduler : sig ... end

Sourcemodule Queue : sig ... end

Sourcetype error = Respd.error

Sourcetype trailers_handler = Headers.t -> unit

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

Sourcetype error_handler = error -> unit

Sourcetype t = {

mutable settings : Settings.t;
reader : Reader.frame;
writer : Writer.t;
config : Config.t;
streams : Scheduler.t;
mutable current_stream_id : Stream_identifier.t;
mutable max_pushed_stream_id : Stream_identifier.t;
mutable current_server_streams : int;
mutable receiving_headers_for_stream : Stream_identifier.t option;
mutable did_send_go_away : bool;
mutable unacked_settings : int;
pending_pings : ((unit, [ `EOF ]) result -> unit) Queue.t;
error_handler : error -> unit;
push_handler : Request.t -> (response_handler, unit) result;
hpack_encoder : Hpack.Encoder.t;
hpack_decoder : Hpack.Decoder.t;

}

Source

val default_push_handler : 
  Request.t ->
  (Response.t -> Body.Reader.t -> unit, 'a) result

Sourceval is_closed : t -> bool

Sourceval shutdown_reader : t -> unit

Sourceval flush_request_body : t -> unit

Sourceval shutdown_writer : t -> unit

Sourceval was_closed_or_implicitly_closed : t -> Int32.t -> bool

Sourceval report_error : t -> Error.t -> unit

Sourceval report_connection_error : t -> ?reason:string -> Error_code.t -> unit

Sourceval report_stream_error : t -> Stream_identifier.t -> Error_code.t -> unit

Sourceval shutdown : t -> unit

Sourceval set_error_and_handle : t -> Respd.t -> Respd.error -> Error_code.t -> unit

Sourceval report_exn : t -> exn -> unit

Source

val send_window_update : 
  'a. t ->
  'a Scheduler.PriorityTreeNode.node ->
  int32 ->
  unit

Source

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

Source

val handle_response_headers : 
  t ->
  Scheduler.nonroot Scheduler.node ->
  end_stream:bool ->
  Respd.active_request ->
  Headers.header list ->
  unit

Source

val handle_headers : 
  t ->
  end_stream:bool ->
  Scheduler.nonroot Scheduler.node ->
  Headers.t ->
  unit

Source

val handle_headers_block : 
  t ->
  ?is_trailers:bool ->
  Scheduler.nonroot Scheduler.node ->
  Stream.partial_headers ->
  int ->
  Angstrom.bigstring ->
  unit

Source

val handle_trailer_headers : 
  t ->
  Scheduler.nonroot Scheduler.node ->
  Stream.partial_headers ->
  int ->
  Angstrom.bigstring ->
  unit

Source

val create_partial_headers : 
  t ->
  int ->
  Bigstringaf.t ->
  Stream.partial_headers

Source

val handle_first_response_bytes : 
  t ->
  Scheduler.nonroot Scheduler.node ->
  Respd.active_request ->
  Frame.frame_header ->
  Bigstringaf.t ->
  unit

Source

val process_trailer_headers : 
  t ->
  Scheduler.nonroot Scheduler.node ->
  Respd.response_info ->
  Frame.frame_header ->
  Angstrom.bigstring ->
  unit

Sourceval process_headers_frame : t -> Frame.t -> Bigstringaf.t -> unit

Sourceval process_data_frame : t -> Frame.t -> Bigstringaf.t -> unit

Source

val on_close_stream : 
  t ->
  Stream_identifier.t ->
  active:bool ->
  Stream.closed ->
  unit

Sourceval process_priority_frame : t -> Frame.t -> Priority.t -> unit

Sourceval process_rst_stream_frame : t -> Frame.t -> Error_code.t -> unit

Sourceval process_settings_frame : t -> Frame.t -> Settings.setting list -> unit

Source

val reserve_stream : 
  t ->
  Frame.t ->
  Stream_identifier.t ->
  Bigstringaf.t ->
  unit

Source

val process_push_promise_frame : 
  t ->
  Frame.t ->
  Int32.t ->
  Bigstringaf.t ->
  unit

Sourceval ok : (unit, 'a) result

Sourceval process_ping_frame : t -> Frame.t -> Faraday.bigstring -> unit

Source

val process_goaway_frame : 
  t ->
  'a ->
  last_stream_id:'b ->
  data:Bigstringaf.t ->
  Error_code.t ->
  unit

Source

val add_window_increment : 
  'a. t ->
  'a Scheduler.PriorityTreeNode.node ->
  int32 ->
  unit

Sourceval process_window_update_frame : t -> Frame.t -> int32 -> unit

Sourceval process_continuation_frame : t -> Frame.t -> Angstrom.bigstring -> unit

Source

val create : 
  ?config:Config.t ->
  ?push_handler:(Request.t -> (response_handler, unit) result) ->
  error_handler:(error -> unit) ->
  unit ->
  t

Source

val create_and_add_stream : 
  t ->
  error_handler:Respd.error_handler ->
  (((Respd.response_info, Respd.response_info Stream.remote_state)
      Stream.active_state,
     Respd.active_request,
     Respd.active_request Stream.remote_state)
     Stream.state,
    Respd.error,
    Respd.error_handler)
    Stream.t

Source

val create_h2c : 
  ?config:Config.t ->
  ?push_handler:(Request.t -> (response_handler, unit) result) ->
  http_request:Httpaf.Request.t ->
  error_handler:(error -> unit) ->
  (Respd.response_handler * Respd.error_handler) ->
  (t, string) result

Source

val request : 
  t ->
  ?flush_headers_immediately:bool ->
  ?trailers_handler:Respd.trailers_handler ->
  Request.t ->
  error_handler:Respd.error_handler ->
  response_handler:Respd.response_handler ->
  Body.Writer.t

Source

val ping : 
  t ->
  ?payload:Bigstringaf.t ->
  ?off:int ->
  ((unit, [ `EOF ]) result -> unit) ->
  unit

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

Sourceval read : t -> Bigstringaf.t -> off:int -> len:int -> int

Sourceval unexpected_eof : t -> unit

Sourceval read_eof : t -> Bigstringaf.t -> off:int -> len:int -> int

Sourceval yield_reader : 'a -> (unit -> 'b) -> 'b

Source

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

Sourceval yield_writer : t -> (unit -> unit) -> unit

Sourceval report_write_result : t -> [< `Closed | `Ok of int ] -> unit