docs: protected static RedisFuture<Long> aggregateAsync(Map<?, ? extends CompletionStage<Long>> executions) {
  
          return new PipelinedRedisFuture<>(executions, objectPipelinedRedisFuture -> {
              AtomicLong result = new AtomicLong();
              for (CompletionStage<Long> future : executions.values()) {
                  Long value = execute(() -> future.toCompletableFuture().get());
                  if (value != null) {
                      result.getAndAdd(value);
                  }
              }
  
              return result.get();
          });
      }