package cohttp-async

  1. Overview
  2. Docs
CoHTTP implementation for the Async concurrency library

Install 

dune-project
 Dependency

github.com Readme Changelog ISC License Edit opam file Versions (11)

Authors

  1. A
    Anil Madhavapeddy
  2. S
    Stefano Zacchiroli
  3. D
    David Sheets
  4. T
    Thomas Gazagnaire
  5. D
    David Scott
  6. R
    Rudi Grinberg
  7. A
    Andy Ray

Maintainers

  1. A
    anil@recoil.org

Sources

cohttp-5.2.0.tbz
sha256=5dba8f26185603fb27f2ebfbadf701232ba8d1b2fe69e65e7253f21af7296f9b
sha512=84c6609964efa65e1d2e51563a985041d73810b85bc25f8e757b45397903e28b4e91979c49afdc8ff1fd79b202ff15f8ec3516ae6ea5c69a25bfa0a2ae46a7ea

doc/cohttp-async/Cohttp_async/Server/index.html

Module Cohttp_async.ServerSource

Sourcetype ('address, 'listening_on) t constraint 'address = [< Async_unix.Socket.Address.t ]
Sourceval sexp_of_t : ('address -> Sexplib0.Sexp.t) -> ('listening_on -> Sexplib0.Sexp.t) -> ('address, 'listening_on) t -> Sexplib0.Sexp.t
Sourceval close : (_, _) t -> unit Async_kernel.Deferred.t
Sourceval close_finished : (_, _) t -> unit Async_kernel.Deferred.t
Sourceval is_closed : (_, _) t -> bool
Sourceval listening_on : (_, 'listening_on) t -> 'listening_on
Sourcetype response = Response.t * Body.t
Sourceval sexp_of_response : response -> Sexplib0.Sexp.t
Sourcetype 'r respond_t = ?flush:bool -> ?headers:Cohttp.Header.t -> ?body:Body.t -> Cohttp.Code.status_code -> 'r Async_kernel.Deferred.t
Sourcetype response_action = [
  1. | `Expert of Cohttp.Response.t * (Async_unix.Reader.t -> Async_unix.Writer.t -> unit Async_kernel.Deferred.t)
  2. | `Response of response
]

A request handler can respond in two ways:

  • Using `Response, with a Response.t and a Body.t.
  • Using `Expert, with a 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.
Sourceval 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.

Sourceval respond_with_pipe : ?flush:bool -> ?headers:Cohttp.Header.t -> ?code:Cohttp.Code.status_code -> 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

Sourceval respond_string : ?flush:bool -> ?headers:Cohttp.Header.t -> ?status:Cohttp.Code.status_code -> string -> response Async_kernel.Deferred.t
Sourceval respond_with_redirect : ?headers:Cohttp.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

Sourceval respond_with_file : ?flush:bool -> ?headers:Cohttp.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

Sourceval 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 -> 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.

Sourceval 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 -> 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