Size: a a a

StartAndroid Ru RxJava

2019 September 28

ИШ

Иван Шамсиев in StartAndroid Ru RxJava
Sanjar Suvonov
#вопрос. здарствуйте Как я могу сделать?
Мне кажется, можно реализовать через RecyclerView, сделав для него свой LayoutManager. Погугли, это не особо сложно
источник

М

Михаил in StartAndroid Ru RxJava
Sanjar Suvonov
#вопрос. здарствуйте Как я могу сделать?
ViewPager
источник
2019 October 01

Д

Денис in StartAndroid Ru RxJava
Добрый день всем.
Помогите мне понять, как перезапустить цепочку в случае конкретной ошибки.
Видимо нужно воспользоваться оператором retryWhen, но что-то я его не могу вкурить.
Задача такова: иду в сеть, если получаю ошибку :
(error as? HttpException)?
.let {
   if (it.code() == 401) {
     // здесь мне нужно запустит цепочку по обновлению токена. и вслучае успеха повторить основной запрос, где я словил текущую ошибку
}}


P.S. тяжко rx постигается мною )
источник

ИЯ

Илья Ярлыкин in StartAndroid Ru RxJava
обновление токена в любом случае происходит в okhttp interception и authentication.
источник
2019 October 06

РВ

Роман Василенко in StartAndroid Ru RxJava
Привет!
Помогите, сломал голову на этом rx. В целом всё понятно, но вот пример:
       BehaviorSubject<String> s1 = BehaviorSubject.create();

       s1.subscribe((s) -> Log.d("app", "s1: " + s));

       BehaviorSubject<String> s2 = BehaviorSubject.create();

       s2.subscribe((s) -> Log.d("app", "s2: " + s));

       s1.onNext("Str1");
       s2.onNext("Str2");

       BehaviorSubject.combineLatest(s1, s2, (str1, str2) -> {
           Log.d("app", "Combined: " + s1 + s2);
           return str1 + str2;
       });

объясните, пожалуйста, почему не срабатывает combineLatest?

Мне посоветовали использовать Observable.combineLatest, но я что-то эффекта не заметил.
источник

AN

Andrey Null in StartAndroid Ru RxJava
Роман Василенко
Привет!
Помогите, сломал голову на этом rx. В целом всё понятно, но вот пример:
       BehaviorSubject<String> s1 = BehaviorSubject.create();

       s1.subscribe((s) -> Log.d("app", "s1: " + s));

       BehaviorSubject<String> s2 = BehaviorSubject.create();

       s2.subscribe((s) -> Log.d("app", "s2: " + s));

       s1.onNext("Str1");
       s2.onNext("Str2");

       BehaviorSubject.combineLatest(s1, s2, (str1, str2) -> {
           Log.d("app", "Combined: " + s1 + s2);
           return str1 + str2;
       });

объясните, пожалуйста, почему не срабатывает combineLatest?

Мне посоветовали использовать Observable.combineLatest, но я что-то эффекта не заметил.
Надо наверно ещё и subscribe сделать?
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
То есть, оно сработает только при наличии подписчика?
источник

AN

Andrey Null in StartAndroid Ru RxJava
Твой комбайн лейтест - да
источник

AN

Andrey Null in StartAndroid Ru RxJava
И результат этому подписчику и прилетит
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
И в самом деле
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
Спасибо
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
А как сделать, чтобы это сразатывало без подписки?
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
Я видел пример, но он оказался очень сложным для меня в тот момент.
источник

[P

[отпуск] Dmitrii Polyakov in StartAndroid Ru RxJava
Роман Василенко
Привет!
Помогите, сломал голову на этом rx. В целом всё понятно, но вот пример:
       BehaviorSubject<String> s1 = BehaviorSubject.create();

       s1.subscribe((s) -> Log.d("app", "s1: " + s));

       BehaviorSubject<String> s2 = BehaviorSubject.create();

       s2.subscribe((s) -> Log.d("app", "s2: " + s));

       s1.onNext("Str1");
       s2.onNext("Str2");

       BehaviorSubject.combineLatest(s1, s2, (str1, str2) -> {
           Log.d("app", "Combined: " + s1 + s2);
           return str1 + str2;
       });

объясните, пожалуйста, почему не срабатывает combineLatest?

Мне посоветовали использовать Observable.combineLatest, но я что-то эффекта не заметил.
Observable.combineLatest и BehaviorSubject.combineLatest ссылаются на одну функцию =)
источник

[P

[отпуск] Dmitrii Polyakov in StartAndroid Ru RxJava
Роман Василенко
А как сделать, чтобы это сразатывало без подписки?
А зачем?
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
Мне надо выполнить операцию с двумя значениями, когда они оба будут готовы
источник

[P

[отпуск] Dmitrii Polyakov in StartAndroid Ru RxJava
Роман Василенко
Мне надо выполнить операцию с двумя значениями, когда они оба будут готовы
И чем мешает подписчик? Делаешь подписку, а исполнение будет, когда будешь готов.
источник

РВ

Роман Василенко in StartAndroid Ru RxJava
[отпуск] Dmitrii Polyakov
И чем мешает подписчик? Делаешь подписку, а исполнение будет, когда будешь готов.
Ну, просто это выглядит как-то... избыточно
источник
2019 October 09

DC

Dyno Chris is... in StartAndroid Ru RxJava
Добрый день.

А как вывести ошибку в лог в блоке trowable? Но при этом чтобы не упало приложение. Так можно?
источник

СП

Сергей Переходов in StartAndroid Ru RxJava
Dyno Chris is...
Добрый день.

А как вывести ошибку в лог в блоке trowable? Но при этом чтобы не упало приложение. Так можно?
да
источник