У меня есть две наблюдаемые, и я использовал concatDelayError для последовательной обработки.
Моя проблема в том, что onNext и onCompleted вызываются заблаговременно до обработки. Как я узнаю, что вся обработка завершена с помощью concatDelayError?
Псевдокод:
public Observable<Integer> concat(){
int x = 10;
int y = 20;
Observable obx = Observable.create(emitter -> {
try {
int x = doSomeThing();
emitter.onNext(x);
emitter.onCompleted();
} catch (SQLiteException e) {
emitter.onError(e);
}
}, Emitter.BackpressureMode.BUFFER);
Observable oby = Observable.create(emitter -> {
try {
int y = doSomeThing();
emitter.onNext(y);
emitter.onCompleted();
} catch (SQLiteException e) {
emitter.onError(e);
}
}, Emitter.BackpressureMode.BUFFER);
Observable concated = Observable.concatDelayError(ob1,ob2)
.compose(applySchedulers())
.replay().autoConnect();
}
//somewhere else
concat().subscribe(mReplaySubject);
//somewhere else
mReplaySubject.subscribe(new Observer<Integer>() {
@Override
public void onCompleted() {
launchActivity(SplashActivity.this, HomeActivity.class);
SplashActivity.this.finish();
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
@Override
public void onNext(Integer value) {
}
});
Я использую answer() с autoConnect() и подписываюсь на ReplySubject, так как мне нужно поделиться одной подпиской.
Observer.onCompleted()
вызывается несколько раз для одной подписки? - person akarnokd   schedule 10.01.2018concated
напрямую безReplaySubject
?replay().autoConnect()
уже выполняет кэширование за вас. - person akarnokd   schedule 10.01.2018