Module Parse.ReaderSource

Sourcetype 'error parse_state =
  1. | Done
  2. | Fail of 'error
  3. | Partial of Bigstringaf.t -> off:int -> len:int -> AU.more -> unit AU.state
Sourcetype 'error t = {
  1. parser : unit Angstrom.t;
  2. mutable parse_state : 'error parse_state;
  3. mutable closed : bool;
}
Sourceval create : (opcode:Websocket.Opcode.t -> is_fin:bool -> len:int -> Payload.t -> 'a) -> 'b t
Sourceval transition : [> `Parse of string list * string ] t -> unit AU.state -> int
Sourceval start : [> `Parse of string list * string ] t -> unit AU.state -> unit
Sourceval read_with_more : [> `Parse of string list * string ] t -> Bigstringaf.t -> off:int -> len:int -> AU.more -> int
Sourceval next : 'a t -> [> `Close | `Error of 'a | `Read ]