package async_extended

  1. Overview
  2. Docs
package async_extended
Legend:
Library
Module
Module type
Parameter
Class
Class type
include module type of struct include Delimited_parsing.Deprecated end
include Delimited_parsing.Deprecated_intf.Deprecated with module Row = Delimited_parsing.Row

All readers defined below will raise if they encounter unparsable content.

val of_reader : ?strip:bool -> ?skip_lines:int -> ?on_parse_error: [ `Raise | `Handle of string Core.Queue.t -> exn -> [ `Continue | `Finish ] ] -> header:Delimited_parsing.Header.t -> ?quote:char -> sep:char -> Async.Reader.t -> Row.t Async.Pipe.Reader.t

of_reader ?quote ?strip ?skip_lines ~sep ~header r returns a row pipe based on data read from the provided reader. sep is used as the separator between fields, and is assumed to be escaped with \ unless quote is given.

val create_reader : ?strip:bool -> ?skip_lines:int -> ?on_parse_error: [ `Raise | `Handle of string Core.Queue.t -> exn -> [ `Continue | `Finish ] ] -> header:Delimited_parsing.Header.t -> ?quote:char -> sep:char -> string -> Row.t Async.Pipe.Reader.t Async.Deferred.t

create_reader ?strip ?skip_lines ~header filename same as of_reader, but creates the reader for you