ursus
09/22/2018, 5:20 PMfun <T, R, S> Observable<T>.emitApiEvents2(
started: () -> R,
success: (T) -> R,
errorr: (S) -> R,
customErrorTransformation: ((Throwable) -> S) = { it }): Observable<R> {
return map { success(it) }
.doOnError(LOG::e)
.onErrorReturn { t -> errorr(customErrorTransformation(t)) }
.startWith(started())
}