| 4479 | } |
| 4480 | |
| 4481 | void AssertStreamEnd(struct ArrowArrayStream* c_stream) { |
| 4482 | struct ArrowArray c_array; |
| 4483 | ASSERT_EQ(0, c_stream->get_next(c_stream, &c_array)); |
| 4484 | |
| 4485 | ArrayExportGuard guard(&c_array); |
| 4486 | ASSERT_TRUE(ArrowArrayIsReleased(&c_array)); |
| 4487 | } |
| 4488 | |
| 4489 | void AssertStreamNext(struct ArrowArrayStream* c_stream, const RecordBatch& expected) { |
| 4490 | struct ArrowArray c_array; |
nothing calls this directly
no test coverage detected