Function ReadMessageFromBlockAsync

cpp/src/arrow/ipc/reader.cc:1295–1303

}

Future<std::shared_ptr<Message>> ReadMessageFromBlockAsync(
    const FileBlock& block, io::RandomAccessFile* file, const io::IOContext& io_context) {
  RETURN_NOT_OK(CheckAligned(block));
  return ReadMessageAsync(block.offset, block.metadata_length, block.body_length, file,
                          io_context)
      .Then([block](std::shared_ptr<Message> message) {
        return CheckBodyLength(std::move(message), block);
      });
}

class RecordBatchFileReaderImpl;