package cohttp-async

  1. Overview
  2. Docs
module B = Cohttp.Body
type t = [
  1. | B.t
  2. | `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