СП
попробуй interval
Size: a a a
2019 July 03
YM
ДР
Абдулмуталим Муртазаев
А мне нужет оператор который пропускает сразу же первый, и не пропускает остальные в течение той же секунды например
throttleFirst ? вроде оно
2019 July 04
AV
Всем привет , подскажите пожалуйста как без переподписки заимитить предыдущий элемент элемент по определенному событию . У меня есть Flowable бесконечный на который подписываюсь , этот fliwable переодически что-то имитит и я хочу получить повтор последнего заимиченного эелемнта если пользователь например нажал кнопку
AV
Не могу понять как сделать без перепрдписки
AV
Можно было бы сделать какой-нибудь combineLast но кажется костылем
2019 July 06
JF
Добрый день. Не очень силен в Rx, поэтому нуждаюсь в вашей помощи.
Есть android приложение которое через dirtyCheck сканирует локальную базу в 2х отдельных потоках в бесконечных циклах.
Как вынести бесконечные циклы в Rx?
Есть android приложение которое через dirtyCheck сканирует локальную базу в 2х отдельных потоках в бесконечных циклах.
Как вынести бесконечные циклы в Rx?
ДР
Посоветуйте оператор или как лучше поступить в данном кейсе: имеется Observable который эмиттит айтемы, нужно чтобы после каждого эммита он ожидал еще по 1 айтему от двух других observableов, а потом отправлял всё это месиво дальше
D
Посоветуйте оператор или как лучше поступить в данном кейсе: имеется Observable который эмиттит айтемы, нужно чтобы после каждого эммита он ожидал еще по 1 айтему от двух других observableов, а потом отправлял всё это месиво дальше
Загугли операторы объединения
D
Их там несколько
D
Выбери под твой кейс
ДР
Спасибо, посмотрю
2019 July 14
Е
Почему нельзя подписаться на observable, а потом применить к нему оператор switchMap? Мне бы как-то ошибки хэндлить на 1 observable
l
Почему нельзя подписаться на observable, а потом применить к нему оператор switchMap? Мне бы как-то ошибки хэндлить на 1 observable
подписка это конечная операция. после нее ничего не может быть. switchMap нужно выставить до подписки
Е
После switchMap будет уже подписка на observable который возвращает switchMap
l
После switchMap будет уже подписка на observable который возвращает switchMap
какая задача?
Е
Первый observable получает cookies с сервера (использую retrofit), затем надо во сделать запрос вместе с этими cookies и сохранить их, соответственно в switchMap сохраняю их и передаю во 2 Observable, который совершает запрос. Но если будет какая-то ошибка при получение Cookies(например, неправильный логин или пароль), то, очевидно, приложение вылетает. Как хэндлить ошибки именно 1 observable пока что не знаю
l
Первый observable получает cookies с сервера (использую retrofit), затем надо во сделать запрос вместе с этими cookies и сохранить их, соответственно в switchMap сохраняю их и передаю во 2 Observable, который совершает запрос. Но если будет какая-то ошибка при получение Cookies(например, неправильный логин или пароль), то, очевидно, приложение вылетает. Как хэндлить ошибки именно 1 observable пока что не знаю
сохранять cookies - doOnNext.
хендлить ошибки - onError*
хендлить ошибки - onError*
l
не вижу здесь кейса именно под свичмап
Е
Чтобы сразу же второй запрос начинать и передавать их во 2 Observable, очень похоже на то, что в RxJava примеры