Module `Dream_httpaf_.Server_connection`Source

Sourcemodule Reader = Parse.Reader

Sourcemodule Writer = Serialize.Writer

Sourcetype request_handler = Reqd.t -> unit

Sourcetype error = [

| `Bad_gateway
| `Bad_request
| `Internal_server_error
| `Exn of exn

]

type error_handler =
  ?request:Request.t ->
  error ->
  (Headers.t -> Body.Writer.t) ->
  unit

Sourcetype error_code =

| No_error
| Error of {
1. request : Request.t option;
2. mutable response_state : Response_state.t;
}

Sourcetype t = {

reader : Reader.request;
writer : Writer.t;
response_body_buffer : Bigstringaf.t;
request_handler : request_handler;
error_handler : error_handler;
request_queue : Reqd.t Queue.t;
mutable error_code : error_code;

}

Sourceval is_closed : t -> bool

Sourceval is_active : t -> bool

Sourceval current_reqd_exn : t -> Reqd.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

Source

val 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
  | `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

Source

val create : 
  ?config:Config.t ->
  ?error_handler:Reqd.error_handler ->
  request_handler ->
  t

Sourceval shutdown_reader : t -> unit

Sourceval shutdown_writer : t -> unit

Source

val error_code : 
  t ->
  [> `Bad_gateway | `Bad_request | `Exn of exn | `Internal_server_error ]
    option

Sourceval shutdown : t -> unit

Sourceval set_error_and_handle : ?request:Request.t -> t -> Reqd.error -> unit

Sourceval report_exn : t -> exn -> unit

Sourceval advance_request_queue : t -> unit

Source

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

Source

val _final_read_operation_for : 
  t ->
  Reqd.t ->
  [> `Close | `Error of Reader.request_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

Sourceval flush_response_error_body : Response_state.t -> unit

Source

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

Source

val _final_write_operation_for : 
  t ->
  Reqd.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_/Server_connection/index.html

Module `Dream_httpaf_.Server_connection`Source

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

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

Module Dream_httpaf_.Server_connectionSource

Module `Dream_httpaf_.Server_connection`Source