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