| 88 | } |
| 89 | |
| 90 | void TestHeaderOnly(TableReaderFactory reader_factory) { |
| 91 | auto header_only_buffer = std::make_shared<Buffer>("a,b,c\n"); |
| 92 | auto input = std::make_shared<io::BufferReader>(header_only_buffer); |
| 93 | ASSERT_OK_AND_ASSIGN( |
| 94 | auto reader, reader_factory(input, ParseOptions::Defaults(), /*block_size=*/{})); |
| 95 | ASSERT_FINISHES_OK_AND_ASSIGN(auto table, reader->ReadAsync()); |
| 96 | ASSERT_EQ(table->schema()->num_fields(), 3); |
| 97 | ASSERT_EQ(table->num_rows(), 0); |
| 98 | } |
| 99 | |
| 100 | void TestHeaderOnlyStreaming(StreamingReaderFactory reader_factory) { |
| 101 | auto header_only_buffer = std::make_shared<Buffer>("a,b,c\n"); |
no test coverage detected