Github user phrocker commented on a diff in the pull request: https://github.com/apache/nifi-minifi-cpp/pull/148#discussion_r145688909 --- Diff: libminifi/include/core/ProcessSession.h --- @@ -151,11 +152,47 @@ class ProcessSession { bool keepSource, uint64_t offset, char inputDelimiter); + /** + * Exports the data stream to a file + * @param string file to export stream to + * @param flow flow file + * @param bool whether or not to keep the content in the flow file + */ + bool exportContent(const std::string &destination, + std::shared_ptr<core::FlowFile> &flow, + bool keepContent); + + bool exportContent(const std::string &destination, + const std::string &tmpFileName, + std::shared_ptr<core::FlowFile> &flow, + bool keepContent); + + // Stash the content to a key + void stash(const std::string &key, std::shared_ptr<core::FlowFile> flow); + // Restore content previously stashed to a key + void restore(const std::string &key, std::shared_ptr<core::FlowFile> flow); + // Prevent default copy constructor and assignment operation // Only support pass by reference or pointer ProcessSession(const ProcessSession &parent) = delete; ProcessSession &operator=(const ProcessSession &parent) = delete; + class ReadCallback : public InputStreamCallback { --- End diff -- Can we move this elsewhere?
---