public ListenableFuture acquireAsync()

in alloydb-jdbc-connector/src/main/java/com/google/cloud/alloydb/AsyncRateLimiter.java [73:80]

• 8 lines of code
• 2 McCabe index (conditional complexity)

  public ListenableFuture<?> acquireAsync(ScheduledExecutorService executor) {
    long limit = this.nextDelayMs(currentTimestampMs.getAsLong());
    if (limit > 0) {
      return Futures.scheduleAsync(
          () -> this.acquireAsync(executor), limit, TimeUnit.MILLISECONDS, executor);
    }
    return Futures.immediateFuture(null);
  }