Method: ADSP::Test::Stream::Reader#test_read_with_large_texts

Defined in:

lib/adsp/test/stream/reader.rb

#test_read_with_large_texts ⇒ Object

# File 'lib/adsp/test/stream/reader.rb', line 161

def test_read_with_large_texts
  options_generator = OCG.new(
    :text        => LARGE_TEXTS,
    :with_buffer => Option::BOOLS
  )

  Common.parallel_options options_generator do |options|
    text        = options[:text]
    with_buffer = options[:with_buffer]

    archive     = get_archive text
    prev_result = "".b

    LARGE_PORTION_LENGTHS.each do |portion_length|
      instance          = target.new ::StringIO.new(archive)
      decompressed_text = "".b

      begin
        loop do
          result =
            if with_buffer
              instance.read portion_length, prev_result
            else
              instance.read portion_length
            end

          break if result.nil?

          assert_equal prev_result, result if with_buffer
          decompressed_text << result
        end
      ensure
        instance.close
      end

      decompressed_text.force_encoding text.encoding
      assert_equal text, decompressed_text
    end

    instance          = target.new ::StringIO.new(archive)
    decompressed_text = nil

    begin
      if with_buffer
        decompressed_text = instance.read nil, prev_result
        assert_equal prev_result, decompressed_text
      else
        decompressed_text = instance.read
      end
    ensure
      instance.close
    end

    decompressed_text.force_encoding text.encoding
    assert_equal text, decompressed_text
  end
end