Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
include module type of Delimited_kernel.Read.Streaming
type 'a builder_t = 'a Delimited_kernel.Read.t
type 'a t = 'a Delimited_kernel.Read.Streaming.t
val create :
?strip:bool ->
?sep:char ->
?quote:[ `No_quoting | `Using of char ] ->
?start_line_number:int ->
?on_invalid_row:'a Delimited_kernel.Read.On_invalid_row.t ->
?header:Delimited_kernel.Read.Header.t ->
'a builder_t ->
init:'b ->
f:('b -> 'a -> 'b) ->
'b t
val create_indexed :
?strip:bool ->
?sep:char ->
?quote:[ `No_quoting | `Using of char ] ->
?start_line_number:int ->
?on_invalid_row:'a Delimited_kernel.Read.On_invalid_row.t ->
?header:Delimited_kernel.Read.Header.t ->
'a builder_t ->
init:'b ->
f:(int -> 'b -> 'a -> 'b) ->
'b t
Like create
, but additionally passes the line number of the current row to f
val acc : 'a t -> 'a
val headers : 'a t -> Core.String.Set.t option
val state : 'a t -> [ `Parsing_header | `Parsing_rows ]
val input_reader : 'a t -> Async.Reader.t -> 'a t Async.Deferred.t
input_reader t reader
feeds all bytes from reader
to the delimited parser. It does not call finish
after reaching EOF
, one need to call it explicitly if needed.
val read_file :
?strip:bool ->
?sep:char ->
?quote:[ `No_quoting | `Using of char ] ->
?start_line_number:int ->
?on_invalid_row:'a On_invalid_row.t ->
?header:Header.t ->
'a builder_t ->
init:'b ->
f:('b -> 'a -> 'b) ->
filename:string ->
'b t Async.Deferred.t
Reads all bytes from filename
and call finish
after reaching EOF
.