Sha256: 1d1d791fddf4fbaef955fa6f2205d93b9d57e7b28a8d1c4adca9ff14ce4bc5c1

Contents?: true

Size: 494 Bytes

Versions: 7

Compression:

Stored size: 494 Bytes

Contents

require 'cucumber/messages/varint'

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 = Cucumber::Messages::Envelope.from_json(line)
            rescue => e
              raise "Not JSON: #{line.strip}"
            end
            yielder.yield(m)
          end
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
cucumber-messages-15.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-14.1.2 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-14.1.1 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-14.1.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-14.0.1 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-14.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-13.2.1 lib/cucumber/messages/ndjson_to_message_enumerator.rb