| 178 | class ClientStreamReader : public FlightStreamReader { |
| 179 | public: |
| 180 | ClientStreamReader(std::shared_ptr<internal::ClientDataStream> stream, |
| 181 | const ipc::IpcReadOptions& options, StopToken stop_token, |
| 182 | std::shared_ptr<MemoryManager> memory_manager) |
| 183 | : stream_(std::move(stream)), |
| 184 | options_(options), |
| 185 | stop_token_(std::move(stop_token)), |
| 186 | memory_manager_(std::move(memory_manager)), |
| 187 | peekable_reader_(new internal::PeekableFlightDataReader(stream_.get())), |
| 188 | app_metadata_(nullptr) {} |
| 189 | |
| 190 | Status EnsureDataStarted() { |
| 191 | if (!batch_reader_) { |