diff --git a/rx-extensions/src/main/java/ru/touchin/extensions/rx/Flowable.kt b/rx-extensions/src/main/java/ru/touchin/extensions/rx/Flowable.kt index 6ed222d..9f2f959 100644 --- a/rx-extensions/src/main/java/ru/touchin/extensions/rx/Flowable.kt +++ b/rx-extensions/src/main/java/ru/touchin/extensions/rx/Flowable.kt @@ -18,6 +18,6 @@ fun Flowable>.unwrapOrError( ?: Flowable.error(ShouldNotHappenException(errorMessage)) } -fun Flowable>.unwrapOrSkip(): Flowable = this +fun Flowable>.unwrapOrFilter(): Flowable = this .filter { it.get() != null } .map { it.get() } diff --git a/rx-extensions/src/main/java/ru/touchin/extensions/rx/Observable.kt b/rx-extensions/src/main/java/ru/touchin/extensions/rx/Observable.kt index 92f9f8e..eb643dd 100644 --- a/rx-extensions/src/main/java/ru/touchin/extensions/rx/Observable.kt +++ b/rx-extensions/src/main/java/ru/touchin/extensions/rx/Observable.kt @@ -18,6 +18,6 @@ fun Observable>.unwrapOrError( ?: Observable.error(ShouldNotHappenException(errorMessage)) } -fun Observable>.unwrapOrSkip(): Observable = this +fun Observable>.unwrapOrFilter(): Observable = this .filter { it.get() != null } .map { it.get() }