RxJavaPriorityScheduler

RxPS - RxJavaPriorityScheduler - A RxJava Priority Scheduler library for Android and Java applications

Overview of RxPS - RxJavaPriorityScheduler library

  • RxPS is used to set the priority for the given task.
  • Simple way to set the priority for the given task.

Using RxPS - RxJavaPriorityScheduler Library in your Android application

Add this in your build.gradle

implementation 'com.mindorks.scheduler:rxps:0.1.0'

Setting low level priority for a task - use RxPS.low()

getObservable()
.subscribeOn(RxPS.low())
.subscribe(getObserver());

// or

getObservable()
.subscribeOn(RxPS.get(Priority.LOW))
.subscribe(getObserver());

Setting medium level priority for a task - use RxPS.medium()

getObservable()
.subscribeOn(RxPS.medium())
.subscribe(getObserver());

// or

getObservable()
.subscribeOn(RxPS.get(Priority.MEDIUM))
.subscribe(getObserver());

Setting high level priority for a task - use RxPS.high()

getObservable()
.subscribeOn(RxPS.high())
.subscribe(getObserver());

// or

getObservable()
.subscribeOn(RxPS.get(Priority.HIGH))
.subscribe(getObserver());

Setting immediate level priority for a task - use RxPS.immediate()

getObservable()
.subscribeOn(RxPS.immediate())
.subscribe(getObserver());

// or

getObservable()
.subscribeOn(RxPS.get(Priority.IMMEDIATE))
.subscribe(getObserver());

TODO

  • Documentation
  • Test Cases
  • Customizations

GitHub