E
как мне single.toObservable но чтоб не вызывался onComplete?
Size: a a a
2020 November 08
l
как мне single.toObservable но чтоб не вызывался onComplete?
у сингла онкомплит в любом случае произойдет. но можно single.toobs соединить с другим потоком, через concat например
E
у сингла онкомплит в любом случае произойдет. но можно single.toobs соединить с другим потоком, через concat например
соеденялся merge, все равно вызывается
l
ну так мержи с бесконечным потоком, например never
l
если у тебя все потоки в соединении конечны, о как ты хочешь без онкомплита?
E
если у тебя все потоки в соединении конечны, о как ты хочешь без онкомплита?
Не прокатывает. Single дергает onComplete и весь поток заканчивается.
l
Не прокатывает. Single дергает onComplete и весь поток заканчивается.
нужен код
l
но выглядеть должно так:
merge(myObs, never).subscribe(...)2020 November 09
E
.flatMap {
Observable.merge(authUseCase.invoke().toObservable(), Observable.never())
}.subscribe()
Observable.merge(authUseCase.invoke().toObservable(), Observable.never())
}.subscribe()
E
E
хотя я еще .onErrorReturn {
when {
it is UserNotRegistered -> true
else -> throw it
}
}
when {
it is UserNotRegistered -> true
else -> throw it
}
}
E
вот так делаю
l
что не сходится? онКомплит разве вызывается в подписке?
E
разобрался
E
там сверху по потоку еще нюанс был
E
прошу прощения за отнятое время
2020 November 11
A
Привет. Может есть знающие люди.
Переписываю тут реактор (webflux) на корутины. Происходит ошибка в одном месте (где она и должна происходить), но при этом логируется она аж от 2-4 потоков. Никто не знает в чём может быть причина? Сам код бежит в
Переписываю тут реактор (webflux) на корутины. Происходит ошибка в одном месте (где она и должна происходить), но при этом логируется она аж от 2-4 потоков. Никто не знает в чём может быть причина? Сам код бежит в
runBlocking на тред пуле JMS очереди (как видно из названия `DefaultMessageListenerContainer`)2020 November 13
K
Всем привет, Подскажите, как можно сделать два Completable на подобии Observable.zip.
Сейчас сделал через костыль... https://pastebin.com/eixwLHad
Сейчас сделал через костыль... https://pastebin.com/eixwLHad
И
MergeArray не подойдёт?
K
MergeArray не подойдёт?
Он же не возвращает результат от Completable-ов