private void notifyWait()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageQueuedNotifier.java [55:63]

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

    private void notifyWait(String pkgId, long offset) {
        CompletableFuture<Long> callback = null;
        if (pkgId != null) {
            callback = receiveCallbacks.remove(pkgId);
        }
        if (callback != null) {
            callback.complete(offset);
        }
    }