Module `Cohttp_async.Body_raw`Source

Sourcemodule B = Cohttp.Body

Sourcetype t = [

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

]

Sourceval sexp_of_t : t -> Sexplib0.Sexp.t

Sourceval empty : [> `Empty ]

Sourceval of_string : string -> t

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

Source

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.Deferred.t

Source

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

Source

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

Sourceval is_empty : t -> bool Async_kernel.Deferred.t

Source

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

Source

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.Deferred.t

Source

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

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

Source

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

Source

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 ]

Source

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

Sourceval of_form : ?scheme:string -> (string * string list) list -> t

Source

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

Source

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

package cohttp-async

Module Cohttp_async.Body_rawSource

Module `Cohttp_async.Body_raw`Source