private void ackAndMaybeNotifyNoPendingFutures()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java [352:360]

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

        private void ackAndMaybeNotifyNoPendingFutures() {
            // When there are no pending futures anymore, notify the thread that is waiting for
            // all the pending futures to be completed.
            if (numPendingFutures.decrementAndGet() == 0) {
                synchronized (numPendingFutures) {
                    numPendingFutures.notify();
                }
            }
        }