Method process

extensions/sftp/processors/PutSFTP.cpp:213–221

PutSFTP::ReadCallback::~ReadCallback() = default;

int64_t PutSFTP::ReadCallback::process(const std::shared_ptr<io::BaseStream>& stream) {
  if (!client_.putFile(target_path_,
      *stream,
      conflict_resolution_ == CONFLICT_RESOLUTION_REPLACE /*overwrite*/,
      stream->size() /*expected_size*/)) {
    throw utils::SFTPException{client_.getLastError()};
  }
  return stream->size();
}

bool PutSFTP::processOne(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSession> &session) {
  auto flow_file = session->get();