public void acquire()

in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/BackpressureSemaphore.java [42:50]

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

  public void acquire(ListenableFuture<T> f) {
    try {
      semaphore.acquire();

      Futures.addCallback(f, this);
    } catch (InterruptedException e) {
      semaphore.release();
    }
  }