``` fun <T, R, S> Observable<T>.emitEv...

# getting-started

[ursus]

fun <T, R, S> Observable<T>.emitEvents(
        started: () -> R,
        success: (T) -> R,
        errorr: (S) -> R,
        customErrorTransformation: (Throwable) -> S): Observable<R> {
    return map(success)
            .doOnError(LOG::e)
            .onErrorReturn { t -> errorr(customErrorTransformation(t)) }
            .startWith(started())
}