From ede0d09a52b9a56c15e3ca26051693ff4d3da3a0 Mon Sep 17 00:00:00 2001 From: lvla Date: Tue, 14 Mar 2017 13:30:53 +0900 Subject: [PATCH] fix typo --- src/main/kotlin/com/lvla/rxjava/interopkt/RxJavaInteropKt.kt | 4 ++-- .../java/com/lvla/rxjava/interopkt/RxJavaInteropKtKtTest.kt | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/kotlin/com/lvla/rxjava/interopkt/RxJavaInteropKt.kt b/src/main/kotlin/com/lvla/rxjava/interopkt/RxJavaInteropKt.kt index b9b096d..c95402e 100644 --- a/src/main/kotlin/com/lvla/rxjava/interopkt/RxJavaInteropKt.kt +++ b/src/main/kotlin/com/lvla/rxjava/interopkt/RxJavaInteropKt.kt @@ -21,7 +21,7 @@ fun rx.Completable.toV2Completable() = RxJavaInterop.toV2Completable(this)!! fun rx.Single.toV2Maybe() = RxJavaInterop.toV2Maybe(this)!! fun rx.Completable.toV2Maybe() = RxJavaInterop.toV2Maybe(this)!! -fun Publisher.toV1Observable() = RxJavaInterop.toV1Observable(this) +fun Publisher.toV1Observable() = RxJavaInterop.toV1Observable(this)!! fun Observable.toV1Observable(strategy: BackpressureStrategy) = RxJavaInterop.toV1Observable(this, strategy)!! fun Single.toV1Single() = RxJavaInterop.toV1Single(this)!! fun Completable.toV1Completable() = RxJavaInterop.toV1Completable(this)!! @@ -30,7 +30,7 @@ fun Maybe.toCompletable() = RxJavaInterop.toV1Completable(this)!! fun rx.subjects.Subject.toV2Subject() = RxJavaInterop.toV2Subject(this)!! -fun rx.subjects.Subject.toV2Provessor() = RxJavaInterop.toV2Processor(this)!! +fun rx.subjects.Subject.toV2Processor() = RxJavaInterop.toV2Processor(this)!! fun Subject.toV1Subject() = RxJavaInterop.toV1Subject(this)!! fun FlowableProcessor.toV1Subject() = RxJavaInterop.toV1Subject(this)!! diff --git a/src/test/java/com/lvla/rxjava/interopkt/RxJavaInteropKtKtTest.kt b/src/test/java/com/lvla/rxjava/interopkt/RxJavaInteropKtKtTest.kt index 4275d32..dbe2653 100644 --- a/src/test/java/com/lvla/rxjava/interopkt/RxJavaInteropKtKtTest.kt +++ b/src/test/java/com/lvla/rxjava/interopkt/RxJavaInteropKtKtTest.kt @@ -119,7 +119,7 @@ class RxJavaInteropKtTest { @Test fun sj1p2() { val s = rx.subjects.PublishSubject.create() - val t = s.toV2Provessor().test() + val t = s.toV2Processor().test() s.hasObservers().should be true