Parse_stream (upsycle-router.Util_encode_decode_io.Parse

val rerun : 
  ((Angstrom.Buffered.unconsumed * ('a, string) Stdlib.result) -> unit Lwt.t) ->
  'a Angstrom.t ->
  Angstrom.Buffered.unconsumed ->
  Lwt_io.input_channel ->
  int ->
  unit Lwt.t

If onok' or onerr' reject, the client connection will be broken.

val get_parser : 
  'a Angstrom.t ->
  Lwt_io.input_channel ->
  (('a -> bool Lwt.t) * (string -> [< `Fail | `Scrub of int ] Lwt.t)) ->
  (Angstrom.Buffered.unconsumed * ('a, string) Stdlib.result) ->
  unit Lwt.t