Module Parse.ReaderSource

Sourcetype request_error = [
  1. | `Bad_request of Request.t
  2. | `Parse of string list * string
]
Sourcetype response_error = [
  1. | `Invalid_response_body_length of Response.t
  2. | `Parse of string list * string
]
Sourcetype 'error parse_state =
  1. | Done
  2. | Fail of 'error
  3. | Partial of Bigstringaf.t -> off:int -> len:int -> AU.more -> (unit, 'error) result AU.state
Sourcetype 'error t = {
  1. parser : (unit, 'error) result Angstrom.t;
  2. mutable parse_state : 'error parse_state;
  3. mutable closed : bool;
  4. mutable wakeup : Optional_thunk.t;
}
Sourcetype request = request_error t
Sourcetype response = response_error t
Sourceval create : (unit, 'a) result Angstrom.t -> 'a t
Sourceval ok : (unit, 'a) result t
Sourceval is_closed : 'a t -> bool
Sourceval on_wakeup : 'a t -> (unit -> unit) -> unit
Sourceval wakeup : 'a t -> unit
Sourceval request : wakeup:(unit -> unit) -> (Request.t -> Body.Reader.t -> 'a) -> [> `Bad_request of Request.t ] t
Sourceval response : Respd.t Queue.t -> [> `Invalid_response_body_length of Response.t ] t
Sourceval transition : ([> `Parse of string list * string ] as 'a) t -> (unit, 'a) result AU.state -> int
Sourceval start : ([> `Parse of string list * string ] as 'a) t -> (unit, 'a) result AU.state -> unit
Sourceval _read_with_more : [> `Parse of string list * string ] t -> Bigstringaf.t -> off:int -> len:int -> AU.more -> int
Sourceval read_with_more : [> `Parse of string list * string ] t -> Bigstringaf.t -> off:int -> len:int -> AU.more -> int
Sourceval force_close : 'a t -> unit
Sourceval next : 'a t -> [> `Close | `Error of 'a | `Read | `Start ]