Module Dream_h2.Server_connectionSource

Sourcemodule Reader = Parse.Reader
Sourcemodule Writer = Serialize.Writer
Sourcemodule Scheduler : sig ... end
Sourcetype request_handler = Reqd.t -> unit
Sourcetype error = [
  1. | `Bad_request
  2. | `Internal_server_error
  3. | `Exn of exn
]
Sourcetype error_handler = ?request:Request.t -> error -> (Headers.t -> Body.Writer.t) -> unit
Sourcetype t = {
  1. mutable settings : Settings.t;
  2. reader : Reader.frame;
  3. writer : Writer.t;
  4. config : Config.t;
  5. request_handler : request_handler;
  6. error_handler : error_handler;
  7. streams : Scheduler.t;
  8. mutable current_client_streams : int;
  9. mutable max_client_stream_id : Stream_identifier.t;
  10. mutable max_pushed_stream_id : Stream_identifier.t;
  11. mutable receiving_headers_for_stream : Stream_identifier.t option;
  12. mutable unacked_settings : int;
  13. mutable did_send_go_away : bool;
  14. hpack_encoder : Hpack.Encoder.t;
  15. hpack_decoder : Hpack.Decoder.t;
}
Sourceval is_closed : t -> bool
Sourceval wakeup_writer : t -> unit
Sourceval shutdown_reader : t -> unit
Sourceval shutdown_writer : t -> unit
Sourceval shutdown : t -> unit
Sourceval was_closed_or_implicitly_closed : t -> Int32.t -> bool
Sourceval report_error : t -> Error.t -> unit
Sourceval report_connection_error : t -> ?additional_debug_data:string -> Error_code.t -> unit
Sourceval report_stream_error : t -> Stream_identifier.t -> Error_code.t -> unit
Sourceval report_exn : t -> exn -> unit
Sourceval on_close_stream : t -> Stream_identifier.t -> active:bool -> Stream.closed -> unit
Sourceval send_window_update : 'a. t -> 'a Scheduler.PriorityTreeNode.node -> int32 -> unit
Sourceval handle_headers : t -> end_stream:bool -> Scheduler.nonroot Scheduler.node -> Reqd.active_stream -> Headers.header list -> unit
Sourceval handle_headers_block : t -> ?is_trailers:bool -> Scheduler.nonroot Scheduler.node -> Reqd.active_stream -> Stream.partial_headers -> int -> Angstrom.bigstring -> unit
Sourceval open_stream : t -> priority:Priority.t -> Int32.t -> Scheduler.nonroot Scheduler.node option
Sourceval process_first_headers_block : t -> Frame.frame_header -> Scheduler.nonroot Scheduler.node -> Bigstringaf.t -> unit
Sourceval process_headers_frame : t -> Frame.t -> priority:Priority.t -> Bigstringaf.t -> unit
Sourceval process_data_frame : t -> Frame.t -> Bigstringaf.t -> unit
Sourceval process_priority_frame : t -> Frame.t -> Priority.t -> unit
Sourceval process_rst_stream_frame : t -> Frame.t -> Error_code.t -> unit
Sourceval apply_settings_list : t -> Settings.setting list -> unit
Sourceval write_settings_frame : t -> ack:bool -> Settings.setting list -> unit
Sourceval process_settings_frame : t -> Frame.t -> Settings.setting list -> unit
Sourceval process_ping_frame : t -> Frame.t -> Faraday.bigstring -> unit
Sourceval process_goaway_frame : t -> 'a -> ('b * 'c * Bigstringaf.t) -> unit
Sourceval 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
Sourceval default_error_handler : ?request:'a -> [< `Bad_gateway | `Bad_request | `Conflict | `Enhance_your_calm | `Exn of exn | `Expectation_failed | `Forbidden | `Gateway_timeout | `Gone | `Http_version_not_supported | `I_m_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Misdirected_request | `Network_authentication_required | `Not_acceptable | `Not_found | `Not_implemented | `Payload_too_large | `Payment_required | `Precondition_failed | `Precondition_required | `Proxy_authentication_required | `Range_not_satisfiable | `Request_header_fields_too_large | `Request_timeout | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unsupported_media_type | `Upgrade_required | `Uri_too_long ] -> (Headers.t -> Body.Writer.t) -> unit
Sourceval write_connection_preface : t -> unit
Sourceval create_generic : h2c:bool -> config:Config.t -> error_handler:error_handler -> request_handler -> t
Sourceval create : ?config:Config.t -> ?error_handler:error_handler -> request_handler -> t
Sourceval handle_h2c_request : t -> Headers.header list -> Faraday.bigstring Httpaf.IOVec.t list -> unit
Sourceval create_h2c : ?config:Config.t -> ?error_handler:error_handler -> http_request:Httpaf.Request.t -> ?request_body:Faraday.bigstring Httpaf.IOVec.t list -> request_handler -> (t, string) result
Sourceval next_read_operation : t -> [> `Close | `Read ]
Sourceval read : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval read_eof : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval yield_reader : 'a -> (unit -> 'b) -> 'b
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
Sourceval yield_writer : t -> (unit -> unit) -> unit