| 492 | } |
| 493 | |
| 494 | static void AssertReadNext(const std::shared_ptr<StreamingReader>& reader, |
| 495 | std::shared_ptr<RecordBatch>* out) { |
| 496 | ASSERT_OK(reader->ReadNext(out)); |
| 497 | ASSERT_FALSE(IsIterationEnd(*out)); |
| 498 | ASSERT_OK((**out).ValidateFull()); |
| 499 | } |
| 500 | static void AssertReadEnd(const std::shared_ptr<StreamingReader>& reader) { |
| 501 | std::shared_ptr<RecordBatch> out; |
| 502 | ASSERT_OK(reader->ReadNext(&out)); |
nothing calls this directly
no test coverage detected