Argumento de tipo explícito Kotlin y RxJava

¿Es esta la única forma posible de usar la compose de ThreadTransformer con ThreadTransformer en Kotlin? Simplemente no me gusta la parte <MyType> en la function de compose . ¿Es posible omitirlo?

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

Observable.compose es una solución para la falta de funciones de extensión en Java. No es necesario utilizar Observable.compose en Kotlin porque admite funciones de extensión Observable.compose para usar:

 // 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() } 

Basado en la respuesta de Vladimir Mironov. Extienda esto a sus necesidades:

 //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 //.. 
  • Rxjava retrofit parse api error para el usuario
  • RxJava- Gire Observable en Iterator, Stream o Sequence
  • Cómo manejar el event handling errores en un solo lugar en rxjava usando wrapper
  • kotlin grpc.StreamObserver para deletar en rx.PublishSubject
  • Cómo get un tipo correcto al devolver Template <T?> Desde una function estática con null
  • Cómo llenar una vista de list usando Kotlin, retroadaptación y RXjava
  • Usando RxJava con Handler, restablece Message.what value
  • La subclass de class sellada de Kotlin debe convertirse a la class base si se proporciona como RxJava Observable
  • Método comodín de Kotlin
  • ¿Cómo puedo pausar que un evento fluya a través de un observable?
  • ¿Por qué tengo un Log de salida no deseado al fusionar 2 observables en otro Observable, que los almacena temporalmente cada 10 segundos?