S
В чем разница между
И
.subscribe({.......}, Throwable::printStackTrace )И
.subscribe(.......)Size: a a a
2020 August 18
S
В случае Exception что происходет?
I
Singular
В случае Exception что происходет?
так можно было протестировать.
в первом случае приложение не упадёт, во втором упадёт
в первом случае приложение не упадёт, во втором упадёт
I
Single.error(Throwable())AD
Single.error(Throwable())а че это такое? просто
Throwable прилетит как обычный элемент)I
а че это такое? просто
Throwable прилетит как обычный элемент)поправил на error
S
спасибо
2020 August 19
S
Как можно сделать два параллельных запроса с RxJava, так чтобы если один из запросов выбросит Exception второй продолжался?
S
Попробовал merge на sample проекте без сетевого запроса. Если первый запрос кидает Exception, то второй не продолжается.
AY
Zip попробуй
i
Как можно сделать два параллельных запроса с RxJava, так чтобы если один из запросов выбросит Exception второй продолжался?
onError(complete,returnItem)
i
Зазиповать их конечно. Но сделать так, чтобы пайплайн не падал. Ещё на котлине люди в sealed классы оборачивают, но имхо это не очень
AD
Zip попробуй
так там точно так же ошибка вылетит сразу)
S
Как можно сделать так, чтобы в двух этих параллельных запросах показать один прогресс бар.
Для этого у меня был Util ный класс, который я использовал c помощью compose(кусок примера util ного класcа ниже). Но сейчас, я так не могу сделать так как merge сразу прекращает выполнение sequence.
public static <T> ObservableTransformer<T, T> applySchedulers() {
return observable -> observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
Для этого у меня был Util ный класс, который я использовал c помощью compose(кусок примера util ного класcа ниже). Но сейчас, я так не могу сделать так как merge сразу прекращает выполнение sequence.
public static <T> ObservableTransformer<T, T> applySchedulers() {
return observable -> observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
i
Как можно сделать так, чтобы в двух этих параллельных запросах показать один прогресс бар.
Для этого у меня был Util ный класс, который я использовал c помощью compose(кусок примера util ного класcа ниже). Но сейчас, я так не могу сделать так как merge сразу прекращает выполнение sequence.
public static <T> ObservableTransformer<T, T> applySchedulers() {
return observable -> observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
Для этого у меня был Util ный класс, который я использовал c помощью compose(кусок примера util ного класcа ниже). Но сейчас, я так не могу сделать так как merge сразу прекращает выполнение sequence.
public static <T> ObservableTransformer<T, T> applySchedulers() {
return observable -> observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
ещё раз, замени на зип и поглощай ошибку. Прогресс показывай на onSubscribe, скрывай на on(зависит от обсервабл типа)Success, onError, onDispose
i
ещё раз, замени на зип и поглощай ошибку. Прогресс показывай на onSubscribe, скрывай на on(зависит от обсервабл типа)Success, onError, onDispose
Я писал RxLoading, который эмитит true при запросе и false, когда запрос завершён, причём его можно вешать на несколько запросов, там инкрементится количество подписок, можешь - так, сейчас покажу
i
i
Можешь подписаться на неё и на true показывать прогресс, на false убирать
AD
чет я выпал немного. почему бы не мапить к true/false текущее количество подписок в потоке? 🤔
AD
fun inc() = processor.publish(count.incrementAndGet())
fun dec() = processor.publish(count.decrementAndGet())
fun observe() = processor.map { it > 0 }