Method setup

c_glib/test/test-stream-decoder.rb:47–63

  end

  def setup
    columns = {
      "enabled": build_boolean_array([true, false, nil, true]),
    }
    @record_batch = build_record_batch(columns)
    @schema = @record_batch.schema

    @buffer = Arrow::ResizableBuffer.new(0)
    output = Arrow::BufferOutputStream.new(@buffer)
    stream_writer = Arrow::RecordBatchStreamWriter.new(output, @schema)
    stream_writer.write_record_batch(@record_batch)
    stream_writer.close
    output.close

    @listener = Listener.new
    @decoder = Arrow::StreamDecoder.new(@listener)
  end

  def test_listener
    assert_equal(@listener, @decoder.listener)