Явный тип аргумента Kotlin и RxJava

Question

Это единственный возможный способ использования RxJava compose с ThreadTransformer в Котлине? Мне просто не нравится номер <MyType> в функции compose. Можно ли это опустить?

override fun call(): Observable<MyType> { 
    return Observable.just(getData()) 
     .compose(threadTransformer.applySchedulers<MyType>()) 
    } 

Answer 1

Observable.compose обходной путь из-за отсутствия функций расширения в Java. Там нет необходимости использовать Observable.compose в Котлин, поскольку он поддерживает функции расширения из коробки:

// default schedulers 
fun <T> Observable<T>.applySchedulers(): Observable<T> { 
    return subscribeOn(Schedulers.computation()).observeOn(AndroidSchedulers.mainThread()) 
} 

// custom transformer 
fun <T> Observable<T>.applySchedulers(transformer: ThreadTransformer): Observable<T> { 
    return compose(transformer.applySchedulers<T>()) 
} 

override fun call(): Observable<MyType> { 
    return Observable.just(getData()).applySchedulers() 
} 

Answer 2

На основании ответа Владимира Миронова. Расширьте это до ваших потребностей:

//Observable 
fun <T> Observable<T>.applyIoScheduler() = applyScheduler(Schedulers.io()) 
fun <T> Observable<T>.applyComputationScheduler() = applyScheduler(Schedulers.computation()) 
private fun <T> Observable<T>.applyScheduler(scheduler: Scheduler) = 
       subscribeOn(scheduler).observeOn(AndroidSchedulers.mainThread()) 

//Single 
fun <T> Single<T>.applyIoScheduler() = applyScheduler(Schedulers.io()) 
fun <T> Single<T>.applyComputationScheduler() = applyScheduler(Schedulers.computation()) 
private fun <T> Single<T>.applyScheduler(scheduler: Scheduler) = 
      subscribeOn(scheduler).observeOn(AndroidSchedulers.mainThread()) 

//Completable 
//..