Method TestDoExchangeError

cpp/src/arrow/flight/test_definitions.cc:541–574

Ensure server errors get propagated no matter what we try

}
// Ensure server errors get propagated no matter what we try
void DataTest::TestDoExchangeError() {
  auto descr = FlightDescriptor::Command("error");
  std::unique_ptr<FlightStreamWriter> writer;
  std::unique_ptr<FlightStreamReader> reader;
  {
    ASSERT_OK_AND_ASSIGN(auto exchange, client_->DoExchange(descr));
    writer = std::move(exchange.writer);
    reader = std::move(exchange.reader);
    auto status = writer->Close();
    EXPECT_RAISES_WITH_MESSAGE_THAT(
        NotImplemented, ::testing::HasSubstr("Expected error"), writer->Close());
  }
  {
    ASSERT_OK_AND_ASSIGN(auto exchange, client_->DoExchange(descr));
    writer = std::move(exchange.writer);
    reader = std::move(exchange.reader);
    EXPECT_RAISES_WITH_MESSAGE_THAT(
        NotImplemented, ::testing::HasSubstr("Expected error"), reader->Next());
    ARROW_UNUSED(writer->Close());
  }
  {
    ASSERT_OK_AND_ASSIGN(auto exchange, client_->DoExchange(descr));
    writer = std::move(exchange.writer);
    reader = std::move(exchange.reader);
    EXPECT_RAISES_WITH_MESSAGE_THAT(
        NotImplemented, ::testing::HasSubstr("Expected error"), reader->GetSchema());
    ARROW_UNUSED(writer->Close());
  }
  // writer->Begin isn't tested here because, as noted in client.cc,
  // OpenRecordBatchWriter lazily writes the initial message - hence
  // Begin() won't fail. Additionally, transports are allowed to
  // buffer writes - a write won't immediately fail even if the server
  // would immediately return an error.
}
void DataTest::TestDoExchangeConcurrency() {
  // Ensure that we can do reads/writes on separate threads
  auto descr = FlightDescriptor::Command("echo");