Method test_consume_buffer

c_glib/test/test-stream-decoder.rb:81–98

  end

  def test_consume_buffer
    # We need to keep data that aren't processed yet.
    data = []
    @buffer.data.to_s.each_byte do |byte|
      data << byte.chr
      can_clear = (@decoder.next_required_size == 1)
      @decoder.consume_buffer(Arrow::Buffer.new(data.last))
      # We can release a reference for kept data after they are
      # processed.
      data.clear if can_clear
    end
    assert_equal([
                   [:schema_decoded, @schema, @schema],
                   [:record_batch_decoded, @record_batch, nil],
                   [:eos],
                 ],
                 @listener.events)
  end

  def test_reset
    @decoder.consume_bytes(@buffer.data.to_s[0, 10])