curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/DistributedQueue.java [360:370]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        synchronized (putCount) {
            putCount.decrementAndGet();
            putCount.notifyAll();
        }
        putListenerContainer.forEach(listener -> {
            if (item != null) {
                listener.putCompleted(item);
            } else {
                listener.putMultiCompleted(givenMultiItem);
            }
        });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/DistributedQueue.java [383:395]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    synchronized (putCount) {
                        putCount.decrementAndGet();
                        putCount.notifyAll();
                    }
                }

                putListenerContainer.forEach(listener -> {
                    if (item != null) {
                        listener.putCompleted(item);
                    } else {
                        listener.putMultiCompleted(givenMultiItem);
                    }
                });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -