cohttp-async 6.0.0~alpha1 · OCaml Package

type ('address, 'listening_on) t constraint 'address = [< Async_unix.Socket.Address.t ]

val sexp_of_t : 
  ('address -> Ppx_sexp_conv_lib.Sexp.t) ->
  ('listening_on -> Ppx_sexp_conv_lib.Sexp.t) ->
  ('address, 'listening_on) t ->
  Ppx_sexp_conv_lib.Sexp.t

val close : (_, _) t -> unit Async_kernel.Deferred.t

val close_finished : (_, _) t -> unit Async_kernel.Deferred.t

val is_closed : (_, _) t -> bool

val listening_on : (_, 'listening_on) t -> 'listening_on

val num_connections : (_, _) t -> int

type response = Http.Response.t * Body.t

val sexp_of_response : response -> Ppx_sexp_conv_lib.Sexp.t

type 'r respond_t =
  ?flush:bool ->
  ?headers:Http.Header.t ->
  ?body:Body.t ->
  Http.Status.t ->
  'r Async_kernel.Deferred.t

type response_action = [

| `Expert of Http.Response.t * (Async_unix.Reader.t -> Async_unix.Writer.t -> unit Async_kernel.Deferred.t)
| `Response of response

]

A request handler can respond in two ways:

Using `Response, with a Http.Response.t and a Body.t.
Using `Expert, with a Http.Response.t and an IO function that is expected to write the response body. The IO function has access to the underlying Async_unix.Reader.t and Async_unix.Writer.t, which allows writing a response body more efficiently, stream a response or to switch protocols entirely (e.g. websockets). Processing of pipelined requests continue after the unitAsync_kernel.Deferred.t is resolved. The connection can be closed by closing the Async_unix.Reader.t.

val respond : response respond_t

val resolve_local_file : docroot:string -> uri:Uri.t -> string

Resolve a URI and a docroot into a concrete local filename.

deprecated Please use Cohttp.Path.resolve_local_file.

val respond_with_pipe : 
  ?flush:bool ->
  ?headers:Http.Header.t ->
  ?code:Http.Status.t ->
  string Async_kernel.Pipe.Reader.t ->
  response Async_kernel.Deferred.t

Respond with a string Pipe that provides the response string Pipe.Reader.t.

parameter code
Default is HTTP 200 `OK

val respond_string : 
  ?flush:bool ->
  ?headers:Http.Header.t ->
  ?status:Http.Status.t ->
  string ->
  response Async_kernel.Deferred.t

val respond_with_redirect : 
  ?headers:Http.Header.t ->
  Uri.t ->
  response Async_kernel.Deferred.t

Respond with a redirect to an absolute uri

parameter uri
Absolute URI to redirect the client to

val respond_with_file : 
  ?flush:bool ->
  ?headers:Http.Header.t ->
  ?error_body:string ->
  string ->
  response Async_kernel.Deferred.t

Respond with file contents, and error_string Pipe.Async_unix.Reader.t if the file isn't found

type mode = Conduit_async.server

val create_expert : 
  ?max_connections:int ->
  ?backlog:int ->
  ?buffer_age_limit:Async_unix.Writer.buffer_age_limit ->
  ?mode:mode ->
  on_handler_error:[ `Call of 'address -> exn -> unit | `Ignore | `Raise ] ->
  ('address, 'listening_on) Async.Tcp.Where_to_listen.t ->
  (body:Body.t ->
    'address ->
    Http.Request.t ->
    response_action Async_kernel.Deferred.t) ->
  ('address, 'listening_on) t Async_kernel.Deferred.t

Build a HTTP server and expose the IO.ic and IO.ocs, based on the Tcp.Server interface.

val create : 
  ?max_connections:int ->
  ?backlog:int ->
  ?buffer_age_limit:Async_unix.Writer.buffer_age_limit ->
  ?mode:Conduit_async.server ->
  on_handler_error:[ `Call of 'address -> exn -> unit | `Ignore | `Raise ] ->
  ('address, 'listening_on) Async.Tcp.Where_to_listen.t ->
  (body:Body.t ->
    'address ->
    Http.Request.t ->
    response Async_kernel.Deferred.t) ->
  ('address, 'listening_on) t Async_kernel.Deferred.t

Build a HTTP server, based on the Tcp.Server interface

module Expert : sig ... end

package cohttp-async