rx-scheduler-transformer
Rxjava2 scheduler transformer tools for RxLife in android.
One nice aspect of RxJava is that you can see how data is transformed through a series of operators:
Observable
.fromCallable(someSource)
.map(data -> manipulate(data))
.subscribeOn(Schedulers.io())
.compose(bindUntilEvent(ActivityEvent.DESTROY))
.observeOn(AndroidSchedulers.mainThread())
.subscribe(data -> doSomething(data));
We frequently use subscribeOn(), compose() and observeOn() because we want to process data in a worker thread then subscribe to it on the main thread and look up the Activity or Fragment lifecycle. Now, this tiny library get you rid of it!
Setup
compile 'com.github.thepacific:transformer:0.0.1'Support
Flowable, Observable, Maybe, Single, and Completable are all supported. Implementation is solely based on their Observer types, so conceivably any type that uses those for subscription should work.
CompletableTransformerUtil for Completable FlowableTransformerUtil for Flowable MaybeTransformerUtil for Maybe ObservableTransformerUtil for Observable SingleTransformerUtil for Single // Transform schedulers // from
Schedulers.io()
to
AndroidSchedulers.mainThread() // from
Schedulers.computation()
to
AndroidSchedulers.mainThread() // from
Schedulers.trampoline()
to
AndroidSchedulers.mainThread() // from
Schedulers.newThread()
to
AndroidSchedulers.mainThread() // from
Schedulers.single()
to
AndroidSchedulers.mainThread() // from
Schedulers.from(executor)
to
AndroidSchedulers.mainThread() Usage
// ObservableTransformerUtil.io(lifecycle(), ActivityEvent.DESTROY)) // ObservableTransformerUtil.computation(lifecycle(), ActivityEvent.DESTROY)) // ObservableTransformerUtil.trampoline(lifecycle(), ActivityEvent.DESTROY)) // ObservableTransformerUtil.newThrea(lifecycle(), ActivityEvent.DESTROY)) // ObservableTransformerUtil.single(lifecycle(), ActivityEvent.DESTROY)) // ObservableTransformerUtil.from(executor, lifecycle(), ActivityEvent.DESTROY)) Observable
.fromCallable(someSource)
.map(data -> manipulate(data))
.compose(ObservableTransformerUtil.io(lifecycle(), ActivityEvent.DESTROY))
.subscribe(data -> doSomething(data));