diff --git a/README.md b/README.md index 89156b6..61f65f9 100644 --- a/README.md +++ b/README.md @@ -13,7 +13,7 @@ RxJava 3: [![Maven Central](https://maven-badges.herokuapp.com/maven-central/io. ```groovy dependencies { - implementation "com.github.akarnokd:rxjava3-bridge:3.0.1" + implementation "com.github.akarnokd:rxjava3-bridge:3.0.2" } ``` diff --git a/gradle.properties b/gradle.properties index 0caf385..f64a124 100644 --- a/gradle.properties +++ b/gradle.properties @@ -1,6 +1,6 @@ GROUP=com.github.akarnokd -VERSION_NAME=3.0.1 -version=3.0.1 +VERSION_NAME=3.0.2 +version=3.0.2 POM_ARTIFACT_ID=rxjava3-bridge POM_NAME=RxJava 3 Bridge to/from RxJava 2 diff --git a/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV2toV3.java b/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV2toV3.java index 5cc224b..eb0a647 100644 --- a/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV2toV3.java +++ b/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV2toV3.java @@ -35,11 +35,8 @@ public void dispose() { } static io.reactivex.rxjava3.disposables.Disposable wrap(io.reactivex.disposables.Disposable disposable) { - if (disposable == io.reactivex.internal.disposables.DisposableHelper.DISPOSED) { - return io.reactivex.rxjava3.internal.disposables.DisposableHelper.DISPOSED; - } - if (disposable == io.reactivex.internal.disposables.EmptyDisposable.INSTANCE) { - return io.reactivex.rxjava3.internal.disposables.EmptyDisposable.INSTANCE; + if (disposable.isDisposed()) { + return io.reactivex.rxjava3.disposables.Disposable.disposed(); } return new DisposableV2toV3(disposable); } diff --git a/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV3toV2.java b/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV3toV2.java index e66a4a4..7312bac 100644 --- a/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV3toV2.java +++ b/src/main/java/hu/akarnokd/rxjava3/bridge/DisposableV3toV2.java @@ -35,11 +35,8 @@ public void dispose() { } static io.reactivex.disposables.Disposable wrap(io.reactivex.rxjava3.disposables.Disposable disposable) { - if (disposable == io.reactivex.rxjava3.internal.disposables.DisposableHelper.DISPOSED) { - return io.reactivex.internal.disposables.DisposableHelper.DISPOSED; - } - if (disposable == io.reactivex.rxjava3.internal.disposables.EmptyDisposable.INSTANCE) { - return io.reactivex.internal.disposables.EmptyDisposable.INSTANCE; + if (disposable.isDisposed()) { + return io.reactivex.disposables.Disposables.disposed(); } return new DisposableV3toV2(disposable); } diff --git a/src/test/java/hu/akarnokd/rxjava3/bridge/RxJavaBridgeTest.java b/src/test/java/hu/akarnokd/rxjava3/bridge/RxJavaBridgeTest.java index e33d526..1a65602 100644 --- a/src/test/java/hu/akarnokd/rxjava3/bridge/RxJavaBridgeTest.java +++ b/src/test/java/hu/akarnokd/rxjava3/bridge/RxJavaBridgeTest.java @@ -501,7 +501,7 @@ public void disposableV2toV3InternalDisposed() { io.reactivex.disposables.Disposable empty = io.reactivex.internal.disposables.DisposableHelper.DISPOSED; io.reactivex.rxjava3.disposables.Disposable disposable = RxJavaBridge.toV3Disposable(empty); - assertSame(disposable, io.reactivex.rxjava3.internal.disposables.DisposableHelper.DISPOSED); + assertSame(disposable, io.reactivex.rxjava3.disposables.Disposable.disposed()); } @Test @@ -509,7 +509,7 @@ public void disposableV2toV3InternalEmpty() { io.reactivex.disposables.Disposable empty = io.reactivex.internal.disposables.EmptyDisposable.INSTANCE; io.reactivex.rxjava3.disposables.Disposable disposable = RxJavaBridge.toV3Disposable(empty); - assertSame(disposable, io.reactivex.rxjava3.internal.disposables.EmptyDisposable.INSTANCE); + assertSame(disposable, io.reactivex.rxjava3.disposables.Disposable.disposed()); } @Test @@ -531,7 +531,7 @@ public void disposableV3toV2InternalDisposed() { io.reactivex.rxjava3.disposables.Disposable empty = io.reactivex.rxjava3.internal.disposables.DisposableHelper.DISPOSED; io.reactivex.disposables.Disposable disposable = RxJavaBridge.toV2Disposable(empty); - assertSame(disposable, io.reactivex.internal.disposables.DisposableHelper.DISPOSED); + assertSame(disposable, io.reactivex.disposables.Disposables.disposed()); } @Test @@ -539,7 +539,7 @@ public void disposableV3toV2InternalEmpty() { io.reactivex.rxjava3.disposables.Disposable empty = io.reactivex.rxjava3.internal.disposables.EmptyDisposable.INSTANCE; io.reactivex.disposables.Disposable disposable = RxJavaBridge.toV2Disposable(empty); - assertSame(disposable, io.reactivex.internal.disposables.EmptyDisposable.INSTANCE); + assertSame(disposable, io.reactivex.disposables.Disposables.disposed()); } // -----------------------------------------------------------