Diamond operators in unit tests, observable package

src/test/java/io/reactivex/rxjava3/internal/operators/observable/BlockingObservableNextTest.java

@@ -63,7 +63,7 @@ public void run() {
  }
 
  static <T> Iterable<T> next(ObservableSource<T> source) {
- return new BlockingObservableNext<T>(source);
+ return new BlockingObservableNext<>(source);
  }
 
  @Test
@@ -356,7 +356,7 @@ public void remove() {
 
  @Test
  public void nextObserverError() {
- NextObserver<Integer> no = new NextObserver<Integer>();
+ NextObserver<Integer> no = new NextObserver<>();
 
  List<Throwable> errors = TestHelper.trackPluginErrors();
  try {
@@ -370,7 +370,7 @@ public void nextObserverError() {
 
  @Test
  public void nextObserverOnNext() throws Exception {
- NextObserver<Integer> no = new NextObserver<Integer>();
+ NextObserver<Integer> no = new NextObserver<>();
 
  no.setWaiting();
  no.onNext(Notification.createOnNext(1));
@@ -383,7 +383,7 @@ public void nextObserverOnNext() throws Exception {
 
  @Test
  public void nextObserverOnCompleteOnNext() throws Exception {
- NextObserver<Integer> no = new NextObserver<Integer>();
+ NextObserver<Integer> no = new NextObserver<>();
 
  no.setWaiting();
  no.onNext(Notification.<Integer>createOnComplete());

src/test/java/io/reactivex/rxjava3/internal/operators/observable/BlockingObservableToIteratorTest.java

@@ -73,7 +73,7 @@ public void subscribe(Observer<? super String> observer) {
 
  @Test
  public void dispose() {
- BlockingObservableIterator<Integer> it = new BlockingObservableIterator<Integer>(128);
+ BlockingObservableIterator<Integer> it = new BlockingObservableIterator<>(128);
 
  assertFalse(it.isDisposed());
 
@@ -84,7 +84,7 @@ public void dispose() {
 
  @Test
  public void interruptWait() {
- BlockingObservableIterator<Integer> it = new BlockingObservableIterator<Integer>(128);
+ BlockingObservableIterator<Integer> it = new BlockingObservableIterator<>(128);
 
  try {
  Thread.currentThread().interrupt();
@@ -97,14 +97,14 @@ public void interruptWait() {
 
  @Test(expected = NoSuchElementException.class)
  public void emptyThrowsNoSuch() {
- BlockingObservableIterator<Integer> it = new BlockingObservableIterator<Integer>(128);
+ BlockingObservableIterator<Integer> it = new BlockingObservableIterator<>(128);
  it.onComplete();
  it.next();
  }
 
  @Test(expected = UnsupportedOperationException.class)
  public void remove() {
- BlockingObservableIterator<Integer> it = new BlockingObservableIterator<Integer>(128);
+ BlockingObservableIterator<Integer> it = new BlockingObservableIterator<>(128);
  it.remove();
  }
 

src/test/java/io/reactivex/rxjava3/internal/operators/observable/Burst.java

@@ -53,7 +53,7 @@ public static <T> Builder<T> item(T item) {
 
  @SafeVarargs
  public static <T> Builder<T> items(T... items) {
- return new Builder<T>(Arrays.asList(items));
+ return new Builder<>(Arrays.asList(items));
  }
 
  public static final class Builder<T> {
@@ -71,7 +71,7 @@ public Observable<T> error(Throwable e) {
  }
 
  public Observable<T> create() {
- return new Burst<T>(error, items);
+ return new Burst<>(error, items);
  }
 
  }

src/test/java/io/reactivex/rxjava3/internal/operators/observable/ObservableAllTest.java

@@ -146,7 +146,7 @@ public Observable<Integer> apply(Boolean t1) {
 
  @Test
  public void predicateThrowsExceptionAndValueInCauseMessageObservable() {
- TestObserverEx<Boolean> to = new TestObserverEx<Boolean>();
+ TestObserverEx<Boolean> to = new TestObserverEx<>();
 
  final IllegalArgumentException ex = new IllegalArgumentException();
 
@@ -277,7 +277,7 @@ public Observable<Integer> apply(Boolean t1) {
 
  @Test
  public void predicateThrowsExceptionAndValueInCauseMessage() {
- TestObserverEx<Boolean> to = new TestObserverEx<Boolean>();
+ TestObserverEx<Boolean> to = new TestObserverEx<>();
 
  final IllegalArgumentException ex = new IllegalArgumentException();
 

src/test/java/io/reactivex/rxjava3/internal/operators/observable/ObservableAmbTest.java

@@ -178,7 +178,7 @@ public void accept(Disposable d) {
  //this stream emits second
  Observable<Integer> o2 = Observable.just(1).doOnSubscribe(incrementer)
  .delay(100, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.computation());
- TestObserver<Integer> to = new TestObserver<Integer>();
+ TestObserver<Integer> to = new TestObserver<>();
  Observable.ambArray(o1, o2).subscribe(to);
  to.awaitDone(5, TimeUnit.SECONDS);
  to.assertNoErrors();
@@ -212,7 +212,7 @@ public void ambCancelsOthers() {
  PublishSubject<Integer> source2 = PublishSubject.create();
  PublishSubject<Integer> source3 = PublishSubject.create();
 
- TestObserver<Integer> to = new TestObserver<Integer>();
+ TestObserver<Integer> to = new TestObserver<>();
 
  Observable.ambArray(source1, source2, source3).subscribe(to);
 

src/test/java/io/reactivex/rxjava3/internal/operators/observable/ObservableAnyTest.java

@@ -247,7 +247,7 @@ public Observable<Integer> apply(Boolean t1) {
 
  @Test
  public void predicateThrowsExceptionAndValueInCauseMessageObservable() {
- TestObserverEx<Boolean> to = new TestObserverEx<Boolean>();
+ TestObserverEx<Boolean> to = new TestObserverEx<>();
  final IllegalArgumentException ex = new IllegalArgumentException();
 
  Observable.just("Boo!").any(new Predicate<String>() {
@@ -469,7 +469,7 @@ public Observable<Integer> apply(Boolean t1) {
 
  @Test
  public void predicateThrowsExceptionAndValueInCauseMessage() {
- TestObserverEx<Boolean> to = new TestObserverEx<Boolean>();
+ TestObserverEx<Boolean> to = new TestObserverEx<>();
  final IllegalArgumentException ex = new IllegalArgumentException();
 
  Observable.just("Boo!").any(new Predicate<String>() {

src/test/java/io/reactivex/rxjava3/internal/operators/observable/ObservableBlockingTest.java

@@ -48,7 +48,7 @@ public void blockingFirstDefault() {
 
  @Test
  public void blockingSubscribeConsumer() {
- final List<Integer> list = new ArrayList<Integer>();
+ final List<Integer> list = new ArrayList<>();
 
  Observable.range(1, 5)
  .subscribeOn(Schedulers.computation())
@@ -64,7 +64,7 @@ public void accept(Integer v) throws Exception {
 
  @Test
  public void blockingSubscribeConsumerConsumer() {
- final List<Object> list = new ArrayList<Object>();
+ final List<Object> list = new ArrayList<>();
 
  Observable.range(1, 5)
  .subscribeOn(Schedulers.computation())
@@ -80,7 +80,7 @@ public void accept(Integer v) throws Exception {
 
  @Test
  public void blockingSubscribeConsumerConsumerError() {
- final List<Object> list = new ArrayList<Object>();
+ final List<Object> list = new ArrayList<>();
 
  TestException ex = new TestException();
 
@@ -100,7 +100,7 @@ public void accept(Object v) throws Exception {
 
  @Test
  public void blockingSubscribeConsumerConsumerAction() {
- final List<Object> list = new ArrayList<Object>();
+ final List<Object> list = new ArrayList<>();
 
  Consumer<Object> cons = new Consumer<Object>() {
  @Override
@@ -123,7 +123,7 @@ public void run() throws Exception {
 
  @Test
  public void blockingSubscribeObserver() {
- final List<Object> list = new ArrayList<Object>();
+ final List<Object> list = new ArrayList<>();
 
  Observable.range(1, 5)
  .subscribeOn(Schedulers.computation())
@@ -156,7 +156,7 @@ public void onComplete() {
 
  @Test
  public void blockingSubscribeObserverError() {
- final List<Object> list = new ArrayList<Object>();
+ final List<Object> list = new ArrayList<>();
 
  final TestException ex = new TestException();
 
@@ -232,7 +232,7 @@ public void utilityClass() {
 
  @Test
  public void disposeUpFront() {
- TestObserver<Object> to = new TestObserver<Object>();
+ TestObserver<Object> to = new TestObserver<>();
  to.dispose();
  Observable.just(1).blockingSubscribe(to);
 
@@ -242,7 +242,7 @@ public void disposeUpFront() {
  @SuppressWarnings("rawtypes")
  @Test
  public void delayed() throws Exception {
- final TestObserver<Object> to = new TestObserver<Object>();
+ final TestObserver<Object> to = new TestObserver<>();
  final Observer[] s = { null };
 
  Schedulers.single().scheduleDirect(new Runnable() {
@@ -271,14 +271,14 @@ protected void subscribeActual(Observer<? super Integer> observer) {
 
  @Test
  public void interrupt() {
- TestObserver<Object> to = new TestObserver<Object>();
+ TestObserver<Object> to = new TestObserver<>();
  Thread.currentThread().interrupt();
  Observable.never().blockingSubscribe(to);
  }
 
  @Test
  public void onCompleteDelayed() {
- TestObserver<Object> to = new TestObserver<Object>();
+ TestObserver<Object> to = new TestObserver<>();
 
  Observable.empty().delay(100, TimeUnit.MILLISECONDS)
  .blockingSubscribe(to);
@@ -288,7 +288,7 @@ public void onCompleteDelayed() {
 
  @Test
  public void blockingCancelUpfront() {
- BlockingFirstObserver<Integer> o = new BlockingFirstObserver<Integer>();
+ BlockingFirstObserver<Integer> o = new BlockingFirstObserver<>();
 
  assertFalse(o.isDisposed());
  o.dispose();