Upgrade to RxJava 1.2.7; use unsafeCreate.

akarnokd · Feb 24, 2017 · 5bda242 · 5bda242
1 parent 19da49d
commit 5bda242
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -17,7 +17,7 @@ Library to convert between RxJava 1.x and 2.x reactive types.
 
 ```
 dependencies {
-    compile "com.github.akarnokd:rxjava2-interop:0.9.1"
+    compile "com.github.akarnokd:rxjava2-interop:0.9.2"
 }
 ```
 

diff --git a/build.gradle b/build.gradle
@@ -49,7 +49,7 @@ dependencies {
     signature 'org.codehaus.mojo.signature:java16:1.1@signature'
 
     compile "org.reactivestreams:reactive-streams:1.0.0"
-    compile "io.reactivex:rxjava:1.2.6"
+    compile "io.reactivex:rxjava:1.2.7"
     compile "io.reactivex.rxjava2:rxjava:2.0.6"
 
     testCompile group: 'junit', name: 'junit', version: '4.12'

diff --git a/gradle.properties b/gradle.properties
@@ -1 +1 @@
-version=0.9.1
+version=0.9.2
diff --git a/src/main/java/hu/akarnokd/rxjava/interop/RxJavaInterop.java b/src/main/java/hu/akarnokd/rxjava/interop/RxJavaInterop.java
@@ -325,7 +325,7 @@ public org.reactivestreams.Subscriber<? super T> apply(org.reactivestreams.Subsc
     @io.reactivex.annotations.SchedulerSupport(io.reactivex.annotations.SchedulerSupport.NONE)
     public static <T> rx.Observable<T> toV1Observable(org.reactivestreams.Publisher<T> source) {
         io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null");
-        return rx.Observable.create(new FlowableV2ToObservableV1<T>(source));
+        return rx.Observable.unsafeCreate(new FlowableV2ToObservableV1<T>(source));
     }
 
     /**

diff --git a/src/test/java/hu/akarnokd/rxjava/interop/RxJavaInteropTest.java b/src/test/java/hu/akarnokd/rxjava/interop/RxJavaInteropTest.java
@@ -171,7 +171,7 @@ public void o1f2ErrorNull() {
 
     @Test
     public void o1f2IgnoreCancel() {
-        toV2Flowable(rx.Observable.create(new OnSubscribe<Object>() {
+        toV2Flowable(rx.Observable.unsafeCreate(new OnSubscribe<Object>() {
             @Override
             public void call(Subscriber<? super Object> s) {
                 s.onNext(null);
@@ -226,7 +226,7 @@ public void o1o2ErrorNull() {
 
     @Test
     public void o1fo2IgnoreCancel() {
-        toV2Observable(rx.Observable.create(new OnSubscribe<Object>() {
+        toV2Observable(rx.Observable.unsafeCreate(new OnSubscribe<Object>() {
             @Override
             public void call(Subscriber<? super Object> s) {
                 s.onNext(null);