| 1215 | // Stream reader constructors |
| 1216 | |
| 1217 | Result<std::shared_ptr<RecordBatchStreamReader>> RecordBatchStreamReader::Open( |
| 1218 | std::unique_ptr<MessageReader> message_reader, const IpcReadOptions& options) { |
| 1219 | // Private ctor |
| 1220 | auto result = |
| 1221 | std::make_shared<RecordBatchStreamReaderImpl>(std::move(message_reader), options); |
| 1222 | RETURN_NOT_OK(result->Init()); |
| 1223 | return result; |
| 1224 | } |
| 1225 | |
| 1226 | Result<std::shared_ptr<RecordBatchStreamReader>> RecordBatchStreamReader::Open( |
| 1227 | io::InputStream* stream, const IpcReadOptions& options) { |