tripkit-android / com.skedgo.rxtry / io.reactivex.Observable
Extensions for io.reactivex.Observable
Name | Summary |
---|---|
toTry | Wraps any error from the upstream which matches predicate into Failure while events emitted via rx.Observer.onNext will be wrapped into Success.fun <T> Observable<T>.toTry(predicate: ( Throwable ) -> Boolean = { true }): Observable< Try <T>> |