| 209 | } |
| 210 | |
| 211 | Result<std::unique_ptr<Message>> Message::ReadFrom(std::shared_ptr<Buffer> metadata, |
| 212 | io::InputStream* stream) { |
| 213 | std::unique_ptr<Message> result; |
| 214 | auto listener = std::make_shared<AssignMessageDecoderListener>(&result); |
| 215 | MessageDecoder decoder(listener, MessageDecoder::State::METADATA, metadata->size()); |
| 216 | ARROW_RETURN_NOT_OK(decoder.Consume(metadata)); |
| 217 | |
| 218 | ARROW_ASSIGN_OR_RAISE(auto body, stream->Read(decoder.next_required_size())); |
| 219 | if (body->size() < decoder.next_required_size()) { |
| 220 | return Status::IOError("Expected to be able to read ", decoder.next_required_size(), |
| 221 | " bytes for message body, got ", body->size()); |
| 222 | } |
| 223 | RETURN_NOT_OK(decoder.Consume(body)); |
| 224 | return result; |
| 225 | } |
| 226 | |
| 227 | Result<std::unique_ptr<Message>> Message::ReadFrom(const int64_t offset, |
| 228 | std::shared_ptr<Buffer> metadata, |
nothing calls this directly
no test coverage detected