| 1429 | ~PayloadStreamWriter() override = default; |
| 1430 | |
| 1431 | Status WritePayload(const IpcPayload& payload) override { |
| 1432 | #ifndef NDEBUG |
| 1433 | // Catch bug fixed in ARROW-3236 |
| 1434 | RETURN_NOT_OK(UpdatePositionCheckAligned()); |
| 1435 | #endif |
| 1436 | |
| 1437 | int32_t metadata_length = 0; // unused |
| 1438 | RETURN_NOT_OK(WriteIpcPayload(payload, options_, sink_, &metadata_length)); |
| 1439 | RETURN_NOT_OK(UpdatePositionCheckAligned()); |
| 1440 | return Status::OK(); |
| 1441 | } |
| 1442 | |
| 1443 | Status Close() override { return WriteEOS(); } |
| 1444 | }; |
nothing calls this directly
no test coverage detected