pekko-connectors-sample-ftp-to-file/src/main/java/playground/filesystem/FileSystemMock.java [54:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void generateFiles(int numFiles, int pageSize, String basePath) {
        String base = "";
        if (!basePath.isEmpty()) {
            if ('/' != basePath.charAt(0)) {
                base = "/" + basePath;
            } else {
                base = basePath;
            }
        }
        int i = 1;
        while (i <= numFiles) {
            int j = i / pageSize;
            String subDir = (j > 0) ? "/dir_" + j : "";
            putFileOnFtp(base + subDir, "sample_" + i);
            i++;
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pekko-connectors-sample-rotate-logs-to-ftp/src/main/java/playground/filesystem/FileSystemMock.java [54:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void generateFiles(int numFiles, int pageSize, String basePath) {
    String base = "";
    if (!basePath.isEmpty()) {
      if ('/' != basePath.charAt(0)) {
        base = "/" + basePath;
      } else {
        base = basePath;
      }
    }
    int i = 1;
    while (i <= numFiles) {
      int j = i / pageSize;
      String subDir = (j > 0) ? "/dir_" + j : "";
      putFileOnFtp(base + subDir, "sample_" + i);
      i++;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -