Size: a a a

ReactiveX - русскоговорящее сообщество

2017 March 01

AK

Aleksei Korshun in ReactiveX - русскоговорящее сообщество
Если конкат, то вроде никак, да и не понимаю зачем
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
а что ты склеивать собрался если у тебя ошибка?
источник

AK

Aleksei Korshun in ReactiveX - русскоговорящее сообщество
Наверное те данные которые без ошибок
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
Artem Gilmudinov
а что ты склеивать собрался если у тебя ошибка?
ну если ошибка, так пусть она будет проброшена после склеивания
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
ну чтобы от обоих обсерваблов в одном месте ошибки ловить
источник

AK

Aleksei Korshun in ReactiveX - русскоговорящее сообщество
Так они и будут в 1 месте, только 1 ошибка, та которая будет первой
источник

AK

Aleksei Korshun in ReactiveX - русскоговорящее сообщество
После чего все закончится
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
Observable<Campaign> observable =  Observable.fromIterable(feedbackInitialData.getAllCampaigns())
                               .takeWhile(Campaign::isStatusPrepareOrReview)
                               .flatMap(campaign -> feedbackRepository
                                       .getIncomingFeedbacks(campaign.getQpfId())
                                       .map(FeedbackResponse::getData)
                                       .flatMapIterable(feedbackDataList -> feedbackDataList)
                                       .map(feedbackData -> {
                                           feedbackData.setCampaignId(campaign.getQpfId());
                                           return feedbackData;
                                       })
                                       .filter(feedbackData -> {
                                           Person reviwer = feedbackData.getReviewer();
                                           return !selectedPerson.getPmcId().equals(reviwer.getPmcId()) &&
                                               reviwer.getQpfId() != selectedPerson.getQpfId();
                                       })
                                       .map(feedbackData -> campaign)
                               )
                               .take(1);

       Observable<Campaign> observableDefault = Observable.fromCallable(() -> feedbackInitialData.getDefaultCampaign())
               .filter(Campaign::isStatusPrepareOrReview)
               .take(1);
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
вот 2 обсервабла
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
мне надо короче если в 1 нет ничего, то брать данные из другого
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
и чтобы ошибка в одном из них не сломала другой
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
onErrorResumeNext?
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
а если в том, который подставлю в onErrorResumeNext случится ошибка, то куда она полетит?
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
в сабскрайбер
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
типо observableDefault.onResumeNext(observable)
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
и вот смотри дальше:

observableDefault.onResumeNext(observable)
.subscribe(....
  public void onError(...){}
)

если ошибка случится в observable, то она в этот еррор прилетит?
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
да
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
а если в observableDefault, то будет продолжено выполнение observable ?
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
не продолжено, а произойдет переключение на observable
источник

AP

Alexey Pushkarev in ReactiveX - русскоговорящее сообщество
и ещё
источник