| 470 | } |
| 471 | |
| 472 | static void AssertReadNext(const std::shared_ptr<StreamingReader>& reader, |
| 473 | std::shared_ptr<RecordBatch>* out) { |
| 474 | ASSERT_OK(reader->ReadNext(out)); |
| 475 | ASSERT_FALSE(IsIterationEnd(*out)); |
| 476 | ASSERT_OK((**out).ValidateFull()); |
| 477 | } |
| 478 | static void AssertReadEnd(const std::shared_ptr<StreamingReader>& reader) { |
| 479 | std::shared_ptr<RecordBatch> out; |
| 480 | ASSERT_OK(reader->ReadNext(&out)); |
nothing calls this directly
no test coverage detected