public List process()

in src/main/java/com/google/cloud/solutions/bqremoteencryptionfn/fns/dlp/DlpRequestBatchExecutor.java [83:100]

• 15 lines of code
• 1 McCabe index (conditional complexity)

  public List<String> process(List<String> rows) throws Exception {

    try (var dlpClient = dlpClientFactory.newClient()) {

      var requestMaker = tableToDlpRequestFnFactory.apply(dlpClient);
      var rowToTableFn = rowsToTableFn();
      var tableToRowsFn = new TableToRowsFn();

      return rowToTableFn.apply(rows).stream()
          .map(requestMaker)
          .map(new RetryingDlpCaller(dlpClient))
          .flatMap(List::stream)
          .map(dlpResponseToTableFn)
          .map(tableToRowsFn)
          .flatMap(List::stream)
          .collect(toList());
    }
  }