Module Parse.ReaderSource

Sourcetype parse_error = [
  1. | `Parse of string list * string
  2. | `Error of Error.t
  3. | `Error_code of Error_code.t
]
Sourcetype 'error parse_state =
  1. | Initial
  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. parse_context : parse_context;
}
Sourcetype frame = parse_error t
Sourceval create : (unit, 'a) result Angstrom.t -> parse_context -> 'a t
Sourceval create_parse_context : int -> parse_context
Sourceval settings_preface : parse_context -> (Frame.t * Settings.settings_list, [> `Error of Error.t ]) result Angstrom.t
Sourceval connection_preface_and_frames : max_frame_size:int -> (parse_context -> ('a * 'b, 'c) result Angstrom.t) -> ('a -> 'b -> 'd) -> ((Frame.t, Error.t) result -> 'e) -> 'c t
Sourceval client_frames : (Frame.t -> Settings.settings_list -> 'a) -> ((Frame.t, Error.t) result -> 'b) -> max_frame_size:int -> [> `Error of Error.t ] t
Sourceval server_frames : max_frame_size:int -> (Frame.t -> Settings.settings_list -> 'a) -> ((Frame.t, Error.t) result -> 'b) -> [> `Error of Error.t ] t
Sourceval is_closed : 'a t -> bool
Sourceval transition : ([> `Error_code of Error_code.t | `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 : [> `Error_code of Error_code.t | `Parse of string list * string ] t -> Bigstringaf.t -> off:int -> len:int -> AU.more -> int
Sourceval force_close : 'a t -> unit
Sourceval fail_to_string : string list -> string -> string
Sourceval next_from_error : 'a t -> ?msg:string -> Error_code.t -> [> `Close | `Error of Error.t | `Read ]
Sourceval next : [< `Error of Error.t | `Error_code of Error_code.t | `Parse of string list * string ] t -> [> `Close | `Error of Error.t | `Read ]