Sha256: 153c590f764f0997f588f642561e38dfe08a62a5e8902ac4023f2b145471f5de
Contents?: true
Size: 1.88 KB
Versions: 13
Compression:
Stored size: 1.88 KB
Contents
module IOStreams
module Row
# Converts each line of an input stream into an array for every line
class Reader
# Read a line as an Array at a time from a file or stream.
def self.open(file_name_or_io,
delimiter: nil,
buffer_size: 65_536,
file_name: nil,
encoding: nil,
encode_cleaner: nil,
encode_replace: nil,
**args)
if file_name_or_io.is_a?(String)
IOStreams.line_reader(file_name_or_io,
delimiter: delimiter,
buffer_size: buffer_size,
file_name: file_name,
encoding: encoding,
encode_cleaner: encode_cleaner,
encode_replace: encode_replace
) do |io|
yield new(io, file_name: file_name, **args)
end
else
yield new(file_name_or_io, **args)
end
end
# Create a Tabular reader to return the stream rows as arrays.
#
# Parameters
# delimited: [#each]
# Anything that returns one line / record at a time when #each is called on it.
#
# format: [Symbol]
# :csv, :hash, :array, :json, :psv, :fixed
#
# For all other parameters, see Tabular::Header.new
def initialize(delimited, cleanse_header: true, **args)
@tabular = IOStreams::Tabular.new(**args)
@delimited = delimited
@cleanse_header = cleanse_header
end
def each
@delimited.each do |line|
if @tabular.header?
columns = @tabular.parse_header(line)
@tabular.cleanse_header! if @cleanse_header
yield columns
else
yield @tabular.row_parse(line)
end
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems