* @return A new blocking queue backed by the delegate
*/
public static <E> @NonNull BlockingQueue<E> offerFailingBlockingQueue(final BlockingQueue<E> delegate) {
- return new ForwardingBlockingQueue<E>() {
+ return new ForwardingBlockingQueue<>() {
@Override
@SuppressWarnings("checkstyle:parameterName")
public boolean offer(final E o) {
protected abstract @NonNull T delegate();
private static <T> ForwardingIdentityObject<T> checkedOf(final @NonNull T delegate) {
- return new ForwardingIdentityObject<T>() {
+ return new ForwardingIdentityObject<>() {
@Override
protected @NonNull T delegate() {
return delegate;
@Override
public @NonNull Iterator<Entry<K, V>> iterator() {
final Iterator<Entry<K, Integer>> it = offsets.entrySet().iterator();
- return new UnmodifiableIterator<Entry<K, V>>() {
+ return new UnmodifiableIterator<>() {
@Override
public boolean hasNext() {
return it.hasNext();
private final class EntrySet extends AbstractSet<Entry<K, V>> {
@Override
public @NonNull Iterator<Entry<K, V>> iterator() {
- return new AbstractSetIterator<Entry<K, V>>() {
+ return new AbstractSetIterator<>() {
@Override
public Entry<K, V> next() {
final K key = nextKey();
private final class KeySet extends AbstractSet<K> {
@Override
public @NonNull Iterator<K> iterator() {
- return new AbstractSetIterator<K>() {
+ return new AbstractSetIterator<>() {
@Override
public K next() {
return nextKey();