| 1125 | ASSERT_RAISES(Invalid, stream->Next()); |
| 1126 | } |
| 1127 | void IpcOptionsTest::TestDoPutWriteOptions() { |
| 1128 | // Call DoPut, but with a very low write nesting depth set to fail the call. |
| 1129 | std::unique_ptr<FlightStreamWriter> writer; |
| 1130 | std::unique_ptr<FlightMetadataReader> reader; |
| 1131 | RecordBatchVector expected_batches; |
| 1132 | ASSERT_OK(ExampleNestedBatches(&expected_batches)); |
| 1133 | |
| 1134 | auto options = FlightCallOptions(); |
| 1135 | options.write_options.max_recursion_depth = 1; |
| 1136 | ASSERT_OK_AND_ASSIGN(auto do_put_result, client_->DoPut(options, FlightDescriptor{}, |
| 1137 | expected_batches[0]->schema())); |
| 1138 | for (const auto& batch : expected_batches) { |
| 1139 | ASSERT_RAISES(Invalid, do_put_result.writer->WriteRecordBatch(*batch)); |
| 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. |
nothing calls this directly
no test coverage detected