public boolean equals()

in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java [472:494]

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

    public boolean equals(Object obj) {
        if (obj == this) {
            return true;
        } else if (obj != null && obj.getClass() == ClosableBlockingQueue.class) {
            @SuppressWarnings("unchecked")
            ClosableBlockingQueue<E> that = (ClosableBlockingQueue<E>) obj;

            if (this.elements.size() == that.elements.size()) {
                Iterator<E> thisElements = this.elements.iterator();
                for (E thatNext : that.elements) {
                    E thisNext = thisElements.next();
                    if (!(thisNext == null ? thatNext == null : thisNext.equals(thatNext))) {
                        return false;
                    }
                }
                return true;
            } else {
                return false;
            }
        } else {
            return false;
        }
    }