| 4797 | } |
| 4798 | |
| 4799 | void AssertReaderClosed(const std::shared_ptr<RecordBatchReader>& reader) { |
| 4800 | ASSERT_THAT(reader->Next(), |
| 4801 | Raises(StatusCode::Invalid, ::testing::HasSubstr("already been closed"))); |
| 4802 | } |
| 4803 | |
| 4804 | void AssertReaderClose(const std::shared_ptr<RecordBatchReader>& reader) { |
| 4805 | ASSERT_OK(reader->Close()); |