| 1140 | } |
| 1141 | } |
| 1142 | void IpcOptionsTest::TestDoExchangeClientWriteOptions() { |
| 1143 | // Call DoExchange and write nested data, but with a very low nesting depth set to |
| 1144 | // fail the call. |
| 1145 | auto options = FlightCallOptions(); |
| 1146 | options.write_options.max_recursion_depth = 1; |
| 1147 | auto descr = FlightDescriptor::Command(""); |
| 1148 | ASSERT_OK_AND_ASSIGN(auto do_exchange_result, client_->DoExchange(options, descr)); |
| 1149 | std::unique_ptr<FlightStreamWriter> writer = std::move(do_exchange_result.writer); |
| 1150 | RecordBatchVector batches; |
| 1151 | ASSERT_OK(ExampleNestedBatches(&batches)); |
| 1152 | ASSERT_OK(writer->Begin(batches[0]->schema())); |
| 1153 | for (const auto& batch : batches) { |
| 1154 | ASSERT_RAISES(Invalid, writer->WriteRecordBatch(*batch)); |
| 1155 | } |
| 1156 | ASSERT_OK(writer->DoneWriting()); |
| 1157 | ASSERT_OK(writer->Close()); |
| 1158 | } |
| 1159 | void IpcOptionsTest::TestDoExchangeClientWriteOptionsBegin() { |
| 1160 | // Call DoExchange and write nested data, but with a very low nesting depth set to |
| 1161 | // fail the call. Here the options are set explicitly when we write data and not in the |
nothing calls this directly
no test coverage detected