Add this in your build.gradle
implementation 'com.mindorks.scheduler:rxps:0.1.0'
getObservable()
.subscribeOn(RxPS.low())
.subscribe(getObserver());
// or
getObservable()
.subscribeOn(RxPS.get(Priority.LOW))
.subscribe(getObserver());
getObservable()
.subscribeOn(RxPS.medium())
.subscribe(getObserver());
// or
getObservable()
.subscribeOn(RxPS.get(Priority.MEDIUM))
.subscribe(getObserver());
getObservable()
.subscribeOn(RxPS.high())
.subscribe(getObserver());
// or
getObservable()
.subscribeOn(RxPS.get(Priority.HIGH))
.subscribe(getObserver());
getObservable()
.subscribeOn(RxPS.immediate())
.subscribe(getObserver());
// or
getObservable()
.subscribeOn(RxPS.get(Priority.IMMEDIATE))
.subscribe(getObserver());