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