I
@angmarr мне не принципиально, просто в образовательных целях) спасибо за помощь)
Вот кстати Kotlin чат - можешь там поспрашивать https://telegram.me/kotlin_lang
Size: a a a
2017 March 11
2017 March 13
AG
Помогите разобраться. http://pastebin.com/KnqL5xGU
В какой-то момент по логам вижу, что в Observable.create subscriber становится isUnsubscribed = true. И, соответственно, в Action1 я уже ничего не получаю.
subscriber.onCompleted(); 100% не вызывался. Почему может произойти отписка, как ее избежать?
В какой-то момент по логам вижу, что в Observable.create subscriber становится isUnsubscribed = true. И, соответственно, в Action1 я уже ничего не получаю.
subscriber.onCompleted(); 100% не вызывался. Почему может произойти отписка, как ее избежать?
AK
чёта жесть
AK
а эррор не приходит?
2017 March 14
IK
У меня есть предположение, что идет отписка сразу по error
AG
As shown in the above diagram, an onError notification from any of the source Observables will immediately be passed through to observers and will terminate the merged Observable.
AG
хотя нихрена там нет на этой диаграмме=)
IK
Как избежать этого ?)
AG
MergeDelayError
IK
Не, не подойдет, нужно получить ошибку как только выкинута, но продолжить работу
AG
дык onError терминальное событие
AG
после него по определению ничего не может быть
IK
грустно, очень грустно
AG
можешь обернуть во что-нибудь ошибку, коль надо
IK
Не сильно хотел это делать, но видать придется, коли хочется запустить приложение в срок
IK
А никак не получится изменить поведение чейна, чтобы onError не завершало его ?
AG
понятия не имею можно ли так.
I
А никак не получится изменить поведение чейна, чтобы onError не завершало его ?
- onErrorReturn(), which replaces onError with a single onNext(value) (followed by onCompleted(), which logically follows the final emission).
- onErrorResumeNext(), which replaces the current stream with an entirely new Observable.
- onErrorResumeNext(), which replaces the current stream with an entirely new Observable.