Sha256: 3af4f8e9ea789d7dcf79fd2778fdcbea2abc6c13c2fbcf2731c3bc412696c883

Contents?: true

Size: 481 Bytes

Versions: 27

Compression:

Stored size: 481 Bytes

Contents

require 'cucumber/messages.deserializers'

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

Version data entries

27 entries across 27 versions & 4 rubygems

Version Path
cucumber-messages-24.1.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-24.0.1 lib/cucumber/messages/ndjson_to_message_enumerator.rb
honeybadger-5.4.0 vendor/bundle/ruby/3.2.0/gems/cucumber-messages-22.0.0/lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-0.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-24.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-23.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
honeybadger-5.3.0 vendor/bundle/ruby/3.2.0/gems/cucumber-messages-21.0.1/lib/cucumber/messages/ndjson_to_message_enumerator.rb
rubypitaya-3.12.5 ./lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/cucumber-messages-18.0.0/lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-22.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
rubypitaya-3.12.4 ./lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/cucumber-messages-18.0.0/lib/cucumber/messages/ndjson_to_message_enumerator.rb
rubypitaya-3.12.3 ./lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/cucumber-messages-18.0.0/lib/cucumber/messages/ndjson_to_message_enumerator.rb
rubypitaya-3.12.2 ./lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/cucumber-messages-18.0.0/lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-21.0.1 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-21.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-20.0.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-19.1.4 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-19.1.3 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-19.1.2 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-19.1.1 lib/cucumber/messages/ndjson_to_message_enumerator.rb
cucumber-messages-19.1.0 lib/cucumber/messages/ndjson_to_message_enumerator.rb