diff --git a/src/main/java/hu/akarnokd/rxjava/interop/RxJavaInterop.java b/src/main/java/hu/akarnokd/rxjava/interop/RxJavaInterop.java index 85ea269..9e04016 100644 --- a/src/main/java/hu/akarnokd/rxjava/interop/RxJavaInterop.java +++ b/src/main/java/hu/akarnokd/rxjava/interop/RxJavaInterop.java @@ -49,7 +49,7 @@ private RxJavaInterop() { * @throws NullPointerException if {@code source} is null */ public static io.reactivex.Flowable toV2Flowable(rx.Observable source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return new ObservableV1ToFlowableV2(source); } @@ -68,7 +68,7 @@ public static io.reactivex.Flowable toV2Flowable(rx.Observable source) * @throws NullPointerException if {@code source} is null */ public static io.reactivex.Observable toV2Observable(rx.Observable source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return new ObservableV1ToObservableV2(source); } @@ -84,7 +84,7 @@ public static io.reactivex.Observable toV2Observable(rx.Observable sou * @throws NullPointerException if {@code source} is null */ public static io.reactivex.Single toV2Single(rx.Single source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return new SingleV1ToSingleV2(source); } @@ -99,7 +99,7 @@ public static io.reactivex.Single toV2Single(rx.Single source) { * @throws NullPointerException if {@code source} is null */ public static io.reactivex.Completable toV2Completable(rx.Completable source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return new CompletableV1ToCompletableV2(source); } @@ -127,7 +127,7 @@ public static io.reactivex.Completable toV2Completable(rx.Completable source) { * @throws NullPointerException if {@code source} is null */ public static rx.Observable toV1Observable(org.reactivestreams.Publisher source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return rx.Observable.create(new FlowableV2ToObservableV1(source)); } @@ -148,8 +148,8 @@ public static rx.Observable toV1Observable(org.reactivestreams.Publisher< * @throws NullPointerException if {@code source} is null */ public static rx.Observable toV1Observable(io.reactivex.ObservableSource source, io.reactivex.BackpressureStrategy strategy) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); - io.reactivex.internal.functions.Objects.requireNonNull(strategy, "strategy is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(strategy, "strategy is null"); return toV1Observable(io.reactivex.Observable.wrap(source).toFlowable(strategy)); } @@ -166,7 +166,7 @@ public static rx.Observable toV1Observable(io.reactivex.ObservableSource< * @throws NullPointerException if {@code source} is null */ public static rx.Single toV1Single(io.reactivex.SingleSource source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return rx.Single.create(new SingleV2ToSingleV1(source)); } @@ -182,7 +182,7 @@ public static rx.Single toV1Single(io.reactivex.SingleSource source) { * @throws NullPointerException if {@code source} is null */ public static rx.Completable toV1Completable(io.reactivex.CompletableSource source) { - io.reactivex.internal.functions.Objects.requireNonNull(source, "source is null"); + io.reactivex.internal.functions.ObjectHelper.requireNonNull(source, "source is null"); return rx.Completable.create(new CompletableV2ToCompletableV1(source)); } }