private void pump()

in src/main/java/com/spotify/futures/ConcurrencyLimiter.java [165:176]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  private void pump() {
    Job<T> job;
    while ((job = grabJob()) != null) {
      final SettableFuture<T> response = job.response;

      if (response.isCancelled()) {
        limit.release();
      } else {
        invoke(response, job.callable);
      }
    }
  }