| 751 | |
| 752 | class ErrorMiddlewareServer : public FlightServerBase { |
| 753 | Status DoAction(const ServerCallContext& context, const Action& action, |
| 754 | std::unique_ptr<ResultStream>* result) override { |
| 755 | std::string msg = "error_message"; |
| 756 | auto buf = Buffer::FromString(""); |
| 757 | |
| 758 | std::shared_ptr<FlightStatusDetail> flightStatusDetail( |
| 759 | new FlightStatusDetail(FlightStatusCode::Failed, msg)); |
| 760 | *result = std::make_unique<SimpleResultStream>(std::vector<Result>{Result{buf}}); |
| 761 | return Status(StatusCode::ExecutionError, "test failed", flightStatusDetail); |
| 762 | } |
| 763 | }; |
| 764 | |
| 765 | class PropagatingTestServer : public FlightServerBase { |
nothing calls this directly
no test coverage detected