Contents

require 'json'

module Cucumber
  module Messages
    class NdjsonToMessageEnumerator < Enumerator
      def initialize(io)
        super() do |yielder|
          io.each_line do |line|
            next if line.strip.empty?
            begin
              m = JSON.parse(line)
            rescue => e
              raise "Not JSON: #{line.strip}"
            end
            yielder.yield(m)
          end
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cucumber-messages-16.0.1	lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-16.0.0	lib/cucumber/messages/ndjson_to_message_enumerator.rb