Upgrade to RxJava 3.0.0-RC7

Author: akarnokd

README.md

@@ -17,7 +17,7 @@ Library to convert between RxJava 1.x and 3.x reactive types.
 
 ```
 dependencies {
-    compile "com.github.akarnokd:rxjava3-interop:3.0.0-RC6"
+    compile "com.github.akarnokd:rxjava3-interop:3.0.0-RC7"
 }
 ```
 

build.gradle

@@ -23,8 +23,8 @@ apply plugin: 'jacoco'
 apply plugin: 'ru.vyarus.animalsniffer'
 apply plugin: "com.github.hierynomus.license"
 
-sourceCompatibility = '1.6'
-targetCompatibility = '1.6'
+sourceCompatibility = JavaVersion.VERSION_1_8
+targetCompatibility = JavaVersion.VERSION_1_8
 
 group = "com.github.akarnokd" 
 ext.githubProjectName = 'rxjava3-interop'
@@ -44,11 +44,11 @@ repositories {
 }
 
 dependencies {
-    signature 'org.codehaus.mojo.signature:java16:1.1@signature'
+    signature 'org.codehaus.mojo.signature:java18:1.0@signature'
 
     compile "org.reactivestreams:reactive-streams:1.0.3"
     compile "io.reactivex:rxjava:1.3.8"
-    compile "io.reactivex.rxjava3:rxjava:3.0.0-RC6"
+    compile "io.reactivex.rxjava3:rxjava:3.0.0-RC7"
 
     testCompile group: 'junit', name: 'junit', version: '4.12'
     testCompile 'org.mockito:mockito-core:3.2.4'

gradle.properties

@@ -1,6 +1,6 @@
 GROUP=com.github.akarnokd
-VERSION_NAME=3.0.0-RC6
-version=3.0.0-RC6
+VERSION_NAME=3.0.0-RC7
+version=3.0.0-RC7
 
 POM_ARTIFACT_ID=rxjava3-interop
 POM_NAME=Interop library between RxJava 1.x and 3.x

src/main/java/hu/akarnokd/rxjava3/interop/FlowableV3ToObservableV1.java

@@ -32,7 +32,7 @@ final class FlowableV3ToObservableV1<T> implements rx.Observable.OnSubscribe<T>
 
     @Override
     public void call(rx.Subscriber<? super T> t) {
-        SourceSubscriber<T> parent = new SourceSubscriber<T>(t);
+        SourceSubscriber<T> parent = new SourceSubscriber<>(t);
 
         t.add(parent);
         t.setProducer(parent);

src/main/java/hu/akarnokd/rxjava3/interop/MaybeV3ToCompletableV1.java

@@ -33,7 +33,7 @@ final class MaybeV3ToCompletableV1<T> implements rx.Completable.OnSubscribe {
 
     @Override
     public void call(rx.CompletableSubscriber t) {
-        MaybeV3Observer<T> parent = new MaybeV3Observer<T>(t);
+        MaybeV3Observer<T> parent = new MaybeV3Observer<>(t);
         t.onSubscribe(parent);
         source.subscribe(parent);
     }

src/main/java/hu/akarnokd/rxjava3/interop/MaybeV3ToSingleV1.java

@@ -34,7 +34,7 @@ final class MaybeV3ToSingleV1<T> implements rx.Single.OnSubscribe<T> {
 
     @Override
     public void call(rx.SingleSubscriber<? super T> t) {
-        MaybeV3Observer<T> parent = new MaybeV3Observer<T>(t);
+        MaybeV3Observer<T> parent = new MaybeV3Observer<>(t);
         t.add(parent);
         source.subscribe(parent);
     }

src/main/java/hu/akarnokd/rxjava3/interop/ObservableV1ToFlowableV3.java

@@ -31,7 +31,7 @@ final class ObservableV1ToFlowableV3<T> extends io.reactivex.rxjava3.core.Flowab
 
     @Override
     protected void subscribeActual(org.reactivestreams.Subscriber<? super T> s) {
-        ObservableSubscriber<T> parent = new ObservableSubscriber<T>(s);
+        ObservableSubscriber<T> parent = new ObservableSubscriber<>(s);
         ObservableSubscriberSubscription parentSubscription = new ObservableSubscriberSubscription(parent);
         s.onSubscribe(parentSubscription);
 

src/main/java/hu/akarnokd/rxjava3/interop/ObservableV1ToObservableV3.java

@@ -31,7 +31,7 @@ final class ObservableV1ToObservableV3<T> extends io.reactivex.rxjava3.core.Obse
 
     @Override
     protected void subscribeActual(io.reactivex.rxjava3.core.Observer<? super T> s) {
-        ObservableSubscriber<T> parent = new ObservableSubscriber<T>(s);
+        ObservableSubscriber<T> parent = new ObservableSubscriber<>(s);
         s.onSubscribe(parent);
 
         source.unsafeSubscribe(parent);

src/main/java/hu/akarnokd/rxjava3/interop/ProcessorV3ToSubjectV1.java

@@ -24,8 +24,8 @@
 final class ProcessorV3ToSubjectV1<T> extends rx.subjects.Subject<T, T> {
 
     static <T> rx.subjects.Subject<T, T> createWith(io.reactivex.rxjava3.processors.FlowableProcessor<T> processor) {
-        State<T> state = new State<T>(processor);
-        return new ProcessorV3ToSubjectV1<T>(state);
+        State<T> state = new State<>(processor);
+        return new ProcessorV3ToSubjectV1<>(state);
     }
 
     final State<T> state;
@@ -67,7 +67,7 @@ static final class State<T>
         @Override
         public void call(rx.Subscriber<? super T> t) {
             hu.akarnokd.rxjava3.interop.FlowableV3ToObservableV1.SourceSubscriber<T> parent =
-                    new hu.akarnokd.rxjava3.interop.FlowableV3ToObservableV1.SourceSubscriber<T>(t);
+                    new hu.akarnokd.rxjava3.interop.FlowableV3ToObservableV1.SourceSubscriber<>(t);
 
             t.add(parent);
             t.setProducer(parent);