Data/com.devbase.data.utilities.rx.transformers/ObservableSchedulerTransformer

Observable Scheduler Transformer

class ObservableSchedulerTransformer<T : Any>(    subscriberScheduler: Scheduler = Schedulers.io(),     observerScheduler: Scheduler = AndroidSchedulers.mainThread(),     delayError: Boolean = false) : ObservableTransformer<T, T>
Content copied to clipboard

Define scheduler to use for Observable

Parameters

T

object to subscribe

subscriberScheduler

scheduler to use when subscribing

observerScheduler

scheduler to use when observing

delayError

stop the stream when there's exception between item emitted

Constructors

Link copied to clipboard
fun ObservableSchedulerTransformer(    subscriberScheduler: Scheduler = Schedulers.io(),     observerScheduler: Scheduler = AndroidSchedulers.mainThread(),     delayError: Boolean = false)
Content copied to clipboard

Functions

Link copied to clipboard
open override fun apply(upstream: Observable<T>): ObservableSource<T>
Content copied to clipboard

Method to apply scheduler

Sources

Link copied to clipboard