cohttp-async 2.2.0 · OCaml Package

module B = Cohttp.Body

type t = [

| B.t
| `Pipe of Base.string Async_kernel.Pipe.Reader.t

]

val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t

val empty : [> `Empty ]

val of_string : string -> t

val of_pipe : 'a -> [> `Pipe of 'a ]

val to_string : 
  [< `Empty
  | `Pipe of Base.String.t Async_kernel.Pipe.Reader.t
  | `String of string
  | `Strings of string list ] ->
  Base.String.t Async_kernel__.Types.Deferred.t

val to_string_list : 
  [< `Empty
  | `Pipe of string Async_kernel.Pipe.Reader.t
  | `String of string
  | `Strings of string list ] ->
  string list Async_kernel__.Types.Deferred.t

val drain : 
  [< `Empty
  | `Pipe of 'a Async_kernel.Pipe.Reader.t
  | `String of string
  | `Strings of string list ] ->
  unit Async_kernel__.Types.Deferred.t

val is_empty : t -> bool Async_kernel__.Types.Deferred.t

val to_pipe : 
  [< `Empty
  | `Pipe of 'a Async_kernel.Pipe.Reader.t
  | `String of 'a
  | `Strings of 'a list ] ->
  'a Async_kernel.Pipe.Reader.t

val disable_chunked_encoding : 
  [< `Empty
  | `Pipe of string Async_kernel.Pipe.Reader.t
  | `String of string
  | `Strings of string list ] ->
  ([> B.t ] * int64) Async_kernel__.Types.Deferred.t

val transfer_encoding : 
  [< `Empty | `Pipe of 'a | `String of string | `Strings of string list ] ->
  Cohttp.Transfer.encoding

val of_string_list : 'a list -> [> `Pipe of 'a Async_kernel.Pipe.Reader.t ]

val map : 
  [< `Empty
  | `Pipe of string Async_kernel.Pipe.Reader.t
  | `String of string
  | `Strings of string list ] ->
  f:(string -> Base.string) ->
  t

val as_pipe : 
  [< `Empty
  | `Pipe of 'a Async_kernel.Pipe.Reader.t
  | `String of 'a
  | `Strings of 'a list ] ->
  f:('a Async_kernel.Pipe.Reader.t -> 'b) ->
  [> `Pipe of 'b ]

val write_body : 
  ('a -> Base.string -> unit Async_kernel.Deferred.t) ->
  t ->
  'a ->
  unit Async_kernel__.Types.Deferred.t

val pipe_of_body : 
  ('a -> Cohttp.Transfer.chunk Async_kernel__.Types.Deferred.t) ->
  'a ->
  string Async_kernel.Pipe.Reader.t

package cohttp-async