PipeErrorTransformer.kt

class NeverErrorTransformer<T>(
        private val errorAction: Consumer<Throwable>?
) : ObservableTransformer<T, T> {

    constructor() : this(null)

    override fun apply(upstream: Observable<T>): ObservableSource<T> {
        return upstream
                .doOnError { e: Throwable -> 
                    Crashlytics.logException(e)
                    errorAction?.accept(e) 
                }
                .onErrorResumeNext(Observable.empty())
    }

}