А
doOnNext(), что ли?
Size: a a a
2017 March 01
N
ммм, сейчас попробую
N
а прямо внутри этого doonnext вызывать flatmap ?
А
не, flatmap это дальше по цепочке
А
что конкретно нужно сделать?
N
просто ессли Obs.fromCallable(ресурс1) мне вернет -1 то я должен продолжить цепочку дальше через Obs.fromCallable(ресурс2) а если допустим -2 , то Obs.fromCallable(ресурс3)
N
или это только внутри сабскайбера , путем вызова новой подписки внутри onComplete ?
AG
а после -1 или -2 уже гарантированно ничего не появится??
А
а если в самом flatMap if-ом разрулить какой Observable возвращать?
N
а после -1 или -2 уже гарантированно ничего не появится??
может быть еще один после
AI
@real_mista а с if во flatMap, действительно,, что? Если не -1 и не -2, то продолжать не надо?
N
я работаю с внешним устройством через ндк
N
оно мне отдает статус выполнения команды
N
там много статусов, но к примеру мне нужно обработать штук 5
N
не, ну через флетмапу вроде как выход , 5 ифов нашлепал и вуаля @InjectViewState =)
AG
я не знаю как прерывать верхний поток, за исключением наличия exception из него. Поэтому предлагаю так.
data.concatMap(v -> {
if(v == -1) {
return Observable.error(new MyError(v));
}
....
}).onErrorResumNext(error -> {
if(error.v == -1) {
}
}....
data.concatMap(v -> {
if(v == -1) {
return Observable.error(new MyError(v));
}
....
}).onErrorResumNext(error -> {
if(error.v == -1) {
}
}....
AI
share() обсервабла и из него ещё 5 с filter(result->result==XX)?
AK
А мне кажется что тут не место rx
N
сейчас у меня адок из асинктасок
AK
Ну наверное его можно причесать