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