Module Piaf.Body

type t
type length = [
| `Fixed of Stdlib.Int64.t
| `Chunked
| `Error of [ `Bad_request | `Bad_gateway | `Internal_server_error ]
| `Unknown
| `Close_delimited
]
val length : t -> length
val empty : t
val of_stream : ?⁠length:length -> Bigstringaf.t IOVec.t Lwt_stream.t -> t
val of_string_stream : ?⁠length:length -> string Lwt_stream.t -> t
val of_string : string -> t
val of_bigstring : ?⁠off:int -> ?⁠len:int -> Bigstringaf.t -> t
val to_string : t -> (string, Error.t) Lwt_result.t
val drain : t -> (unit, Error.t) Lwt_result.t
val is_closed : t -> bool
val closed : t -> (unit, Error.t) Lwt_result.t
val when_closed : t -> ((unit, Error.t) Stdlib.result -> unit) -> unit

Traversal

val fold : (Bigstringaf.t IOVec.t -> 'a -> 'a) -> t -> 'a -> ('a, Error.t) Lwt_result.t
val fold_string : (string -> 'a -> 'a) -> t -> 'a -> ('a, Error.t) Lwt_result.t
val fold_s : (Bigstringaf.t Faraday.iovec -> 'a -> 'a Lwt.t) -> t -> 'a -> ('a, Error.t) Lwt_result.t
val fold_string_s : (string -> 'a -> 'a Lwt.t) -> t -> 'a -> ('a, Error.t) Lwt_result.t
val iter : (Bigstringaf.t Faraday.iovec -> unit) -> t -> (unit, Error.t) Lwt_result.t
val iter_string : (string -> unit) -> t -> (unit, Error.t) Lwt_result.t
val iter_s : (Bigstringaf.t Faraday.iovec -> unit Lwt.t) -> t -> (unit, Error.t) Lwt_result.t
val iter_string_s : (string -> unit Lwt.t) -> t -> (unit, Error.t) Lwt_result.t
val iter_p : (Bigstringaf.t Faraday.iovec -> unit Lwt.t) -> t -> (unit, Error.t) Lwt_result.t
val iter_string_p : (string -> unit Lwt.t) -> t -> (unit, Error.t) Lwt_result.t
val iter_n : ?⁠max_concurrency:int -> (Bigstringaf.t Faraday.iovec -> unit Lwt.t) -> t -> (unit, Error.t) Lwt_result.t
val iter_string_n : ?⁠max_concurrency:int -> (string -> unit Lwt.t) -> t -> (unit, Error.t) Lwt_result.t

Conversion to Lwt_stream.t

val to_stream : t -> Bigstringaf.t IOVec.t Lwt_stream.t * (unit, Error.t) Lwt_result.t
val to_string_stream : t -> string Lwt_stream.t * (unit, Error.t) Lwt_result.t