fix typo

MoyuruAizawa · Mar 14, 2017 · ede0d09 · ede0d09
1 parent cc4fb85
commit ede0d09
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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 <T> rx.Single<T>.toV2Maybe() = RxJavaInterop.toV2Maybe(this)!!
 fun <T> rx.Completable.toV2Maybe() = RxJavaInterop.toV2Maybe<T>(this)!!
 
-fun <T> Publisher<T>.toV1Observable() = RxJavaInterop.toV1Observable(this)
+fun <T> Publisher<T>.toV1Observable() = RxJavaInterop.toV1Observable(this)!!
 fun <T> Observable<T>.toV1Observable(strategy: BackpressureStrategy) = RxJavaInterop.toV1Observable(this, strategy)!!
 fun <T> Single<T>.toV1Single() = RxJavaInterop.toV1Single(this)!!
 fun Completable.toV1Completable() = RxJavaInterop.toV1Completable(this)!!
@@ -30,7 +30,7 @@ fun <T> Maybe<T>.toCompletable() = RxJavaInterop.toV1Completable(this)!!
 
 
 fun <T> rx.subjects.Subject<T, T>.toV2Subject() = RxJavaInterop.toV2Subject(this)!!
-fun <T> rx.subjects.Subject<T, T>.toV2Provessor() = RxJavaInterop.toV2Processor(this)!!
+fun <T> rx.subjects.Subject<T, T>.toV2Processor() = RxJavaInterop.toV2Processor(this)!!
 
 fun <T> Subject<T>.toV1Subject() = RxJavaInterop.toV1Subject(this)!!
 fun <T> FlowableProcessor<T>.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
@@ -119,7 +119,7 @@ class RxJavaInteropKtTest {
  @Test
  fun sj1p2() {
  val s = rx.subjects.PublishSubject.create<Int>()
- val t = s.toV2Provessor().test()
+ val t = s.toV2Processor().test()
 
  s.hasObservers().should be true