Method process

extensions/sftp/processors/FetchSFTP.cpp:160–165

FetchSFTP::WriteCallback::~WriteCallback() = default;

int64_t FetchSFTP::WriteCallback::process(const std::shared_ptr<io::BaseStream>& stream) {
  if (!client_.getFile(remote_file_, *stream)) {
    throw utils::SFTPException{client_.getLastError()};
  }
  return stream->size();
}

void FetchSFTP::onTrigger(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSession> &session) {
  auto flow_file = session->get();