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

Flowable Scheduler Transformer

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

Define scheduler to use for Flowable

Parameters

T

object to subscribe

subscriberScheduler

scheduler to use when subscribing

observerScheduler

scheduler to use when observing

delayError

keep the observer even when there's exception

Constructors

Link copied to clipboard
fun FlowableSchedulerTransformer(    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: Flowable<T>): Publisher<T>
Content copied to clipboard

Method to apply scheduler

Sources

Link copied to clipboard