| 232 | } |
| 233 | |
| 234 | Status WriteMetadata(std::shared_ptr<Buffer> app_metadata) override { |
| 235 | FlightPayload payload{}; |
| 236 | payload.app_metadata = app_metadata; |
| 237 | ARROW_ASSIGN_OR_RAISE(auto success, stream_->WriteData(payload)); |
| 238 | if (!success) { |
| 239 | ARROW_RETURN_NOT_OK(Close()); |
| 240 | return MakeFlightError(FlightStatusCode::Internal, |
| 241 | "Could not write metadata to stream (client disconnect?)"); |
| 242 | } |
| 243 | return Status::OK(); |
| 244 | } |
| 245 | |
| 246 | Status WriteWithMetadata(const RecordBatch& batch, |
| 247 | std::shared_ptr<Buffer> app_metadata) override { |
nothing calls this directly
no test coverage detected