diff options
Diffstat (limited to 'android/guava/src/com/google/common/collect/Queues.java')
-rw-r--r-- | android/guava/src/com/google/common/collect/Queues.java | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/android/guava/src/com/google/common/collect/Queues.java b/android/guava/src/com/google/common/collect/Queues.java index b3121bb64..4525f2623 100644 --- a/android/guava/src/com/google/common/collect/Queues.java +++ b/android/guava/src/com/google/common/collect/Queues.java @@ -55,7 +55,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // ArrayBlockingQueue public static <E> ArrayBlockingQueue<E> newArrayBlockingQueue(int capacity) { - return new ArrayBlockingQueue<E>(capacity); + return new ArrayBlockingQueue<>(capacity); } // ArrayDeque @@ -66,7 +66,7 @@ public final class Queues { * @since 12.0 */ public static <E> ArrayDeque<E> newArrayDeque() { - return new ArrayDeque<E>(); + return new ArrayDeque<>(); } /** @@ -77,9 +77,9 @@ public final class Queues { */ public static <E> ArrayDeque<E> newArrayDeque(Iterable<? extends E> elements) { if (elements instanceof Collection) { - return new ArrayDeque<E>((Collection<? extends E>) elements); + return new ArrayDeque<>((Collection<? extends E>) elements); } - ArrayDeque<E> deque = new ArrayDeque<E>(); + ArrayDeque<E> deque = new ArrayDeque<>(); Iterables.addAll(deque, elements); return deque; } @@ -90,7 +90,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // ConcurrentLinkedQueue public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() { - return new ConcurrentLinkedQueue<E>(); + return new ConcurrentLinkedQueue<>(); } /** @@ -102,9 +102,9 @@ public final class Queues { public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue( Iterable<? extends E> elements) { if (elements instanceof Collection) { - return new ConcurrentLinkedQueue<E>((Collection<? extends E>) elements); + return new ConcurrentLinkedQueue<>((Collection<? extends E>) elements); } - ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<E>(); + ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<>(); Iterables.addAll(queue, elements); return queue; } @@ -119,7 +119,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // LinkedBlockingDeque public static <E> LinkedBlockingDeque<E> newLinkedBlockingDeque() { - return new LinkedBlockingDeque<E>(); + return new LinkedBlockingDeque<>(); } /** @@ -131,7 +131,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // LinkedBlockingDeque public static <E> LinkedBlockingDeque<E> newLinkedBlockingDeque(int capacity) { - return new LinkedBlockingDeque<E>(capacity); + return new LinkedBlockingDeque<>(capacity); } /** @@ -145,9 +145,9 @@ public final class Queues { @GwtIncompatible // LinkedBlockingDeque public static <E> LinkedBlockingDeque<E> newLinkedBlockingDeque(Iterable<? extends E> elements) { if (elements instanceof Collection) { - return new LinkedBlockingDeque<E>((Collection<? extends E>) elements); + return new LinkedBlockingDeque<>((Collection<? extends E>) elements); } - LinkedBlockingDeque<E> deque = new LinkedBlockingDeque<E>(); + LinkedBlockingDeque<E> deque = new LinkedBlockingDeque<>(); Iterables.addAll(deque, elements); return deque; } @@ -158,7 +158,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // LinkedBlockingQueue public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { - return new LinkedBlockingQueue<E>(); + return new LinkedBlockingQueue<>(); } /** @@ -169,7 +169,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // LinkedBlockingQueue public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(int capacity) { - return new LinkedBlockingQueue<E>(capacity); + return new LinkedBlockingQueue<>(capacity); } /** @@ -184,9 +184,9 @@ public final class Queues { @GwtIncompatible // LinkedBlockingQueue public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(Iterable<? extends E> elements) { if (elements instanceof Collection) { - return new LinkedBlockingQueue<E>((Collection<? extends E>) elements); + return new LinkedBlockingQueue<>((Collection<? extends E>) elements); } - LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<E>(); + LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<>(); Iterables.addAll(queue, elements); return queue; } @@ -206,7 +206,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // PriorityBlockingQueue public static <E extends Comparable> PriorityBlockingQueue<E> newPriorityBlockingQueue() { - return new PriorityBlockingQueue<E>(); + return new PriorityBlockingQueue<>(); } /** @@ -224,9 +224,9 @@ public final class Queues { public static <E extends Comparable> PriorityBlockingQueue<E> newPriorityBlockingQueue( Iterable<? extends E> elements) { if (elements instanceof Collection) { - return new PriorityBlockingQueue<E>((Collection<? extends E>) elements); + return new PriorityBlockingQueue<>((Collection<? extends E>) elements); } - PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<E>(); + PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<>(); Iterables.addAll(queue, elements); return queue; } @@ -242,7 +242,7 @@ public final class Queues { */ @SuppressWarnings("rawtypes") // https://github.com/google/guava/issues/989 public static <E extends Comparable> PriorityQueue<E> newPriorityQueue() { - return new PriorityQueue<E>(); + return new PriorityQueue<>(); } /** @@ -258,9 +258,9 @@ public final class Queues { public static <E extends Comparable> PriorityQueue<E> newPriorityQueue( Iterable<? extends E> elements) { if (elements instanceof Collection) { - return new PriorityQueue<E>((Collection<? extends E>) elements); + return new PriorityQueue<>((Collection<? extends E>) elements); } - PriorityQueue<E> queue = new PriorityQueue<E>(); + PriorityQueue<E> queue = new PriorityQueue<>(); Iterables.addAll(queue, elements); return queue; } @@ -271,7 +271,7 @@ public final class Queues { @J2ktIncompatible @GwtIncompatible // SynchronousQueue public static <E> SynchronousQueue<E> newSynchronousQueue() { - return new SynchronousQueue<E>(); + return new SynchronousQueue<>(); } /** |