toTry

\ fun <T> Observable<T>.toTry(predicate: (Throwable) -> Boolean = { true }): Observable<Try<T>>

fun <T> Single<T>.toTry(predicate: (Throwable) -> Boolean = { true }): Single<Try<T>>

Wraps any error from the upstream which matches predicate into Failure while events emitted via rx.Observer.onNext will be wrapped into Success.