Method process

libminifi/src/utils/ByteArrayCallback.cpp:33–42

namespace utils {

int64_t ByteOutputCallback::process(const std::shared_ptr<io::BaseStream>& stream) {
  stream->seek(0);
  if (stream->size() > 0) {
    std::unique_ptr<char> buffer = std::unique_ptr<char>(new char[stream->size()]);
    readFully(buffer.get(), stream->size());
    stream->read(reinterpret_cast<uint8_t*>(buffer.get()), gsl::narrow<int>(stream->size()));
    return stream->size();
  }
  return size_.load();
}

int64_t StreamOutputCallback::process(const std::shared_ptr<io::BaseStream>& stream) {
  stream->seek(0);