Expliziter Typ Argument Kotlin und RxJava

Question

Ist dies die einzige Möglichkeit, RxJavas compose mit ThreadTransformer in Kotlin zu verwenden? Ich mag einfach nicht die <MyType> Teil in compose Funktion. Ist es möglich, es wegzulassen?

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

Answer 1

Observable.compose ist eine Abhilfe für den Mangel an Erweiterungsfunktionen in Java. Es besteht keine Notwendigkeit Observable.compose in Kotlin zu verwenden, da es Erweiterungsfunktionen aus der Box unterstützt:

// 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

Basierend auf Vladimir Mironov Antwort. Erweitern Sie dies auf Ihre Bedürfnisse:

//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 
//..