Class: IOStreams::Row::Reader

Inherits:
Object
  • Object
show all
Defined in:
lib/io_streams/row/reader.rb

Overview

Converts each line of an input stream into an array for every line

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(delimited, cleanse_header: true, **args) ⇒ Reader

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



40
41
42
43
44
 
# File 'lib/io_streams/row/reader.rb', line 40

def initialize(delimited, cleanse_header: true, **args)
  @tabular        = IOStreams::Tabular.new(**args)
  @delimited      = delimited
  @cleanse_header = cleanse_header
end

Class Method Details

.open(file_name_or_io, delimiter: nil, buffer_size: 65_536, file_name: nil, encoding: nil, encode_cleaner: nil, encode_replace: nil, **args) ⇒ Object

Read a line as an Array at a time from a file or stream.



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/io_streams/row/reader.rb', line 6

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

Instance Method Details

#each ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/io_streams/row/reader.rb', line 46

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