| 98 | } |
| 99 | |
| 100 | void TestHeaderOnlyStreaming(StreamingReaderFactory reader_factory) { |
| 101 | auto header_only_buffer = std::make_shared<Buffer>("a,b,c\n"); |
| 102 | auto input = std::make_shared<io::BufferReader>(header_only_buffer); |
| 103 | ASSERT_OK_AND_ASSIGN(auto reader, reader_factory(input)); |
| 104 | std::shared_ptr<RecordBatch> next_batch; |
| 105 | ASSERT_OK(reader->ReadNext(&next_batch)); |
| 106 | ASSERT_EQ(next_batch, nullptr); |
| 107 | } |
| 108 | |
| 109 | void TestStraddling(TableReaderFactory reader_factory) { |
| 110 | // The largest line is 25 bytes, it is surrounded by many valid lines |