class StreamLines::Reading::JSONLines

Attributes

url[R]

Public Class Methods

new(url, encoding: Encoding.default_external, **json_options) click to toggle source
# File lib/stream_lines/reading/json_lines.rb, line 11
def initialize(url, encoding: Encoding.default_external, **json_options)
  @url = url
  @json_options = json_options
  @stream = Stream.new(url, encoding: encoding)
end

Public Instance Methods

each(&block) click to toggle source
# File lib/stream_lines/reading/json_lines.rb, line 17
def each(&block)
  @stream.each { |line| block.call(parse_line(line)) }
end

Private Instance Methods

parse_line(line) click to toggle source
# File lib/stream_lines/reading/json_lines.rb, line 25
def parse_line(line)
  JSON.parse(line, **@json_options)
end