CPD Results

The following document contains the results of PMD's CPD 5.3.2.

Duplications

File Project Line
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueue.java rxjava-extras 292
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueueMemoryMapped.java rxjava-extras 146
	}

	@Override
	public boolean contains(Object o) {
		throw new UnsupportedOperationException();
	}

	@Override
	public Iterator<T> iterator() {
		throw new UnsupportedOperationException();
	}

	@Override
	public Object[] toArray() {
		throw new UnsupportedOperationException();
	}

	@SuppressWarnings("hiding")
	@Override
	public <T> T[] toArray(T[] a) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean remove(Object o) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean containsAll(Collection<?> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean addAll(Collection<? extends T> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean removeAll(Collection<?> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean retainAll(Collection<?> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public void clear() {
		throw new UnsupportedOperationException();
	}
File Project Line
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueue.java rxjava-extras 290
com/github/davidmoten/rx/internal/operators/RollingSPSCQueue.java rxjava-extras 205
	public T remove() {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean contains(Object o) {
		throw new UnsupportedOperationException();
	}

	@Override
	public Iterator<T> iterator() {
		throw new UnsupportedOperationException();
	}

	@Override
	public Object[] toArray() {
		throw new UnsupportedOperationException();
	}

	@SuppressWarnings("hiding")
	@Override
	public <T> T[] toArray(T[] a) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean remove(Object o) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean containsAll(Collection<?> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean addAll(Collection<? extends T> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean removeAll(Collection<?> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public boolean retainAll(Collection<?> c) {
		throw new UnsupportedOperationException();
	}

	@Override
	public void clear() {
File Project Line
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueueMemoryMapped.java rxjava-extras 146
com/github/davidmoten/rx/internal/operators/RollingSPSCQueue.java rxjava-extras 207
    }

    @Override
    public boolean contains(Object o) {
        throw new UnsupportedOperationException();
    }

    @Override
    public Iterator<T> iterator() {
        throw new UnsupportedOperationException();
    }

    @Override
    public Object[] toArray() {
        throw new UnsupportedOperationException();
    }

    @SuppressWarnings("hiding")
    @Override
    public <T> T[] toArray(T[] a) {
        throw new UnsupportedOperationException();
    }

    @Override
    public boolean remove(Object o) {
        throw new UnsupportedOperationException();
    }

    @Override
    public boolean containsAll(Collection<?> c) {
        throw new UnsupportedOperationException();
    }

    @Override
    public boolean addAll(Collection<? extends T> c) {
        throw new UnsupportedOperationException();
    }

    @Override
    public boolean removeAll(Collection<?> c) {
        throw new UnsupportedOperationException();
    }

    @Override
    public boolean retainAll(Collection<?> c) {
        throw new UnsupportedOperationException();
    }

    @Override
    public void clear() {
File Project Line
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java rxjava-extras 155
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java rxjava-extras 277
        public BoundedAfterSubscriber(Subscriber<? super List<T>> actual, int capacityHint,
                Func1<? super T, Boolean> predicate, int prefetch) {
            super(actual, capacityHint, predicate, prefetch);
        }
        
        @Override
        void drain() {
            if (wip.getAndIncrement() != 0) {
                return;
            }
            
            final Subscriber<? super List<T>> localSubscriber = actual;
            final Queue<Object> localQueue = queue;
            int missed = 1;
            
            for (;;) {

                long localRequested = requested.get();
                long localEmission = 0L;
                long localConsumption = 0L;
                List<T> localBuffer = buffer;
                
                while (localEmission != localRequested) {
                    if (localSubscriber.isUnsubscribed()) {
                        return;
                    }
                    
                    boolean mainDone = done;
                    
                    if (mainDone) {
                        Throwable exception = error;
                        if (exception != null) {
                            buffer = null;
                            localSubscriber.onError(exception);
                            return;
                        }
                    }
                    
                    Object notification = localQueue.poll();
File Project Line
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java rxjava-extras 231
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java rxjava-extras 354
                }
                
                if (localEmission == localRequested) {
                    if (localSubscriber.isUnsubscribed()) {
                        return;
                    }
                    
                    boolean mainDone = done;

                    if (mainDone) {
                        Throwable exception = error;
                        if (exception != null) {
                            buffer = null;
                            localSubscriber.onError(exception);
                            return;
                        } else
                        if (localQueue.isEmpty() && localBuffer.isEmpty()) {
                            buffer = null;
                            localSubscriber.onCompleted();
                            return;
                        }
                    }
                }
                
                if (localEmission != 0L) {
                    BackpressureUtils.produced(requested, localEmission);
                }
                if (localConsumption != 0L) {
                    long p = upstreamConsumed + localConsumption;