Skip to content

Commit

Permalink
Showing 1 changed file with 0 additions and 23 deletions.
Original file line number Diff line number Diff line change
@@ -11,11 +11,8 @@

import java.util.Collection;
import java.util.Iterator;
import java.util.Spliterator;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.function.Predicate;
import java.util.stream.Stream;

public class DelegatingBlockingQueue<T> implements BlockingQueue<T> {

@@ -109,21 +106,6 @@ public int size() {
return queue.size();
}

@Override
public Stream<T> parallelStream() {
return queue.parallelStream();
}

@Override
public Stream<T> stream() {
return queue.stream();
}

@Override
public Spliterator<T> spliterator() {
return queue.spliterator();
}

@Override
public int hashCode() {
return queue.hashCode();
@@ -144,11 +126,6 @@ public boolean retainAll(Collection<?> c) {
return queue.retainAll(c);
}

@Override
public boolean removeIf(Predicate<? super T> filter) {
return queue.removeIf(filter);
}

@Override
public boolean removeAll(Collection<?> c) {
return queue.removeAll(c);

0 comments on commit 17243b2

Please sign in to comment.