Rxjava2 kotlin extension

Rx2 Kotlin Extension

fun <T> Flowable<T>.applySchedulersIO(): Flowable<T> {
    return subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
}

fun <T> Flowable<T>.applySchedulersComputation(): Flowable<T> {
    return subscribeOn(Schedulers.computation()).observeOn(AndroidSchedulers.mainThread())
}

fun <T> Flowable<T>.subscribeUIToIO(onNext: (T) -> Unit, onError: (Throwable) -> Unit): Disposable {
    return applySchedulersIO().subscribe({ next ->
        onNext(next)
    }, { error ->
        onError(error)
    })
}

fun <T> Flowable<T>.subscribeUIToComputation(onNext: (T) -> Unit, onError: (Throwable) -> Unit): Disposable {
    return applySchedulersComputation().subscribe({ next ->
        onNext(next)
    }, { error ->
        onError(error)
    })
}