class FlatKit::Jsonl::Reader

Attributes

count[R]
input[R]

Public Class Methods

format_name() click to toggle source
# File lib/flat_kit/jsonl/reader.rb, line 7
def self.format_name
  ::FlatKit::Jsonl::Format.format_name
end
new(source:, compare_fields: :none) click to toggle source
Calls superclass method FlatKit::Reader::new
# File lib/flat_kit/jsonl/reader.rb, line 11
def initialize(source:, compare_fields: :none)
  super
  @input = ::FlatKit::Input.from(source)
  @count = 0
end

Public Instance Methods

each() { |record| ... } click to toggle source
# File lib/flat_kit/jsonl/reader.rb, line 17
def each
  while line = input.io.gets do
    record = ::FlatKit::Jsonl::Record.new(data: line, compare_fields: compare_fields)
    @count += 1
    yield record
  end
  input.close
rescue => e
  ::FlatKit.logger.error "Error reading jsonl records from #{input.name}: #{e}"
  raise ::FlatKit::Error, e
end