@@ -2008,7 +2008,7 @@ public Single<Integer> call(Integer v) {
2008
2008
@ Test
2009
2009
public void flatMapCompletableComplete () {
2010
2010
final AtomicInteger atomicInteger = new AtomicInteger ();
2011
- TestSubscriber testSubscriber = TestSubscriber .create ();
2011
+ TestSubscriber < Object > testSubscriber = TestSubscriber .create ();
2012
2012
2013
2013
Single .just (1 ).flatMapCompletable (new Func1 <Integer , Completable >() {
2014
2014
@ Override
@@ -2030,7 +2030,7 @@ public void call() {
2030
2030
@ Test
2031
2031
public void flatMapCompletableError () {
2032
2032
final RuntimeException error = new RuntimeException ("some error" );
2033
- TestSubscriber testSubscriber = TestSubscriber .create ();
2033
+ TestSubscriber < Object > testSubscriber = TestSubscriber .create ();
2034
2034
2035
2035
Single .just (1 ).flatMapCompletable (new Func1 <Integer , Completable >() {
2036
2036
@ Override
@@ -2044,7 +2044,7 @@ public Completable call(final Integer integer) {
2044
2044
2045
2045
@ Test
2046
2046
public void flatMapCompletableNullCompletable () {
2047
- TestSubscriber testSubscriber = TestSubscriber .create ();
2047
+ TestSubscriber < Object > testSubscriber = TestSubscriber .create ();
2048
2048
2049
2049
Single .just (1 ).flatMapCompletable (new Func1 <Integer , Completable >() {
2050
2050
@ Override
@@ -2058,7 +2058,7 @@ public Completable call(final Integer integer) {
2058
2058
2059
2059
@ Test
2060
2060
public void flatMapCompletableException () {
2061
- TestSubscriber testSubscriber = TestSubscriber .create ();
2061
+ TestSubscriber < Object > testSubscriber = TestSubscriber .create ();
2062
2062
2063
2063
Single .just (1 ).flatMapCompletable (new Func1 <Integer , Completable >() {
2064
2064
@ Override
0 commit comments