Function MakeSerialFactory

cpp/src/arrow/csv/reader_test.cc:245–254

}

TableReaderFactory MakeSerialFactory() {
  return [](std::shared_ptr<io::InputStream> input_stream, ParseOptions parse_options,
            std::optional<int32_t> block_size) {
    auto read_options = ReadOptions::Defaults();
    read_options.block_size = block_size.value_or(1 << 10);
    read_options.use_threads = false;
    return TableReader::Make(io::default_io_context(), input_stream, read_options,
                             std::move(parse_options), ConvertOptions::Defaults());
  };
}

TEST(SerialReaderTests, Empty) { TestEmptyTable(MakeSerialFactory()); }
TEST(SerialReaderTests, HeaderOnly) { TestHeaderOnly(MakeSerialFactory()); }