| 1442 | |
| 1443 | struct StreamDecoderDataWriterHelper : public StreamDecoderWriterHelper { |
| 1444 | Status DoConsume(StreamDecoder* decoder) override { |
| 1445 | // This data is valid only in this function. |
| 1446 | ARROW_ASSIGN_OR_RAISE(auto temporary_buffer, |
| 1447 | Buffer::Copy(buffer_, arrow::default_cpu_memory_manager())); |
| 1448 | return decoder->Consume(temporary_buffer->data(), temporary_buffer->size()); |
| 1449 | } |
| 1450 | }; |
| 1451 | |
| 1452 | struct StreamDecoderBufferWriterHelper : public StreamDecoderWriterHelper { |