Contents

module DeadlySerious
  module Engine
    class JsonIo
      include Enumerable

      def initialize(io)
        @io = io
      end

      def each
        return enum_for(:each) unless block_given?
        @io.each { |line| yield parse(line) }
      end

      def <<(value)
        case value
          when Hash
            @io << "#{MultiJson.dump(value)}\n"
          else
            @io << "#{MultiJson.dump(Array(value))}\n"
        end
      end

      def flush
        @io.flush
      end

      private
      def parse(line)
        MultiJson.load(line)
      rescue MultiJson::ParseError
        puts 'Error in parse'
        puts line
        raise
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
deadly_serious-2.0.0.pre.rc4	lib/deadly_serious/engine/json_io.rb
deadly_serious-2.0.0.pre.rc3	lib/deadly_serious/engine/json_io.rb
deadly_serious-2.0.0.pre.rc2	lib/deadly_serious/engine/json_io.rb
deadly_serious-2.0.0.pre.rc1	lib/deadly_serious/engine/json_io.rb