| 4738 | } |
| 4739 | |
| 4740 | void AssertReaderClosed(const std::shared_ptr<RecordBatchReader>& reader) { |
| 4741 | ASSERT_THAT(reader->Next(), |
| 4742 | Raises(StatusCode::Invalid, ::testing::HasSubstr("already been closed"))); |
| 4743 | } |
| 4744 | |
| 4745 | void AssertReaderClose(const std::shared_ptr<RecordBatchReader>& reader) { |
| 4746 | ASSERT_OK(reader->Close()); |