| 1879 | } |
| 1880 | |
| 1881 | void AsyncClientTest::TestGetFlightInfoFuture() { |
| 1882 | auto descr = FlightDescriptor::Command("status-outofmemory"); |
| 1883 | auto future = client_->GetFlightInfoAsync(descr); |
| 1884 | ASSERT_FINISHES_AND_RAISES(UnknownError, future); |
| 1885 | ASSERT_THAT(future.status().ToString(), ::testing::HasSubstr("Sentinel")); |
| 1886 | |
| 1887 | descr = FlightDescriptor::Command("my_command"); |
| 1888 | future = client_->GetFlightInfoAsync(descr); |
| 1889 | ASSERT_FINISHES_OK_AND_ASSIGN(auto info, future); |
| 1890 | // See test_util.cc:ExampleFlightInfo |
| 1891 | ASSERT_EQ(descr, info.descriptor()); |
| 1892 | ASSERT_EQ(1000, info.total_records()); |
| 1893 | ASSERT_EQ(100000, info.total_bytes()); |
| 1894 | } |
| 1895 | |
| 1896 | void AsyncClientTest::TestListenerLifetime() { |
| 1897 | arrow::Future<FlightInfo> future = arrow::Future<FlightInfo>::Make(); |
nothing calls this directly
no test coverage detected