A
processor which uses RxJava for creating observables.
Passing this class to
Performer
allows you to return an
Observable
from Performer instance.
Observable observable =
performer.convertTo(RxJavaPerformProcessor.INSTANCE);
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
// handle errors
}
@Override
public void onNext(QBSession qbSession) {
// session created
}
});