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

Package com. devbase. data. utilities. rx. transformers

Defines transform schedulers for Rx

Types

class CompletableSchedulerTransformer(subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread()) : CompletableTransformer

Define scheduler to use for Completable

FlowableSchedulerTransformer

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

Define scheduler to use for Flowable

MaybeSchedulerTransformer

class MaybeSchedulerTransformer<T : Any>(subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread()) : MaybeTransformer<T, T>

Define scheduler to use for Maybe

ObservableSchedulerTransformer

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

Define scheduler to use for Observable

SingleSchedulerTransformer

class SingleSchedulerTransformer<T : Any>(subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread()) : SingleTransformer<T, T>

Define scheduler to use for Single

Functions

completableScheduler

fun <T> completableScheduler(subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread()): CompletableSchedulerTransformer

flowableScheduler

fun <T : Any> flowableScheduler( subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread(), delayError: Boolean = false): FlowableSchedulerTransformer<T>

maybeScheduler

fun <T : Any> maybeScheduler(subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread()): MaybeSchedulerTransformer<T>

observableScheduler

fun <T : Any> observableScheduler( subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread(), delayError: Boolean = false): ObservableSchedulerTransformer<T>

singleScheduler

fun <T : Any> singleScheduler(subscriberScheduler: Scheduler = Schedulers.io(), observerScheduler: Scheduler = AndroidSchedulers.mainThread()): SingleSchedulerTransformer<T>