Size: a a a

ReactiveX - русскоговорящее сообщество

2017 March 10

KZ

Konstantin Zolotov in ReactiveX - русскоговорящее сообщество
Ну либо вручную unsubscribe/dispose и снова.
источник

KZ

Konstantin Zolotov in ReactiveX - русскоговорящее сообщество
Но если это в цепочке, то switchMap
источник

IK

Igor Komarov in ReactiveX - русскоговорящее сообщество
Предположим есть Observable, который несколько раз flatMap-пится. Нигде не прописано ни subscribeOn, ни observeOn. Получаем его в другом компоненте, добавляем subscribeOn(io), observerOn(AndroidSchedulers.mainThread()). Какой результат ожидать - будет ли вся цепочка идти на io, либо же только часть после последнего flatMap-а ?
источник

М

Михаил in ReactiveX - русскоговорящее сообщество
Igor Komarov
Предположим есть Observable, который несколько раз flatMap-пится. Нигде не прописано ни subscribeOn, ни observeOn. Получаем его в другом компоненте, добавляем subscribeOn(io), observerOn(AndroidSchedulers.mainThread()). Какой результат ожидать - будет ли вся цепочка идти на io, либо же только часть после последнего flatMap-а ?
без кода непонятно. там есть операторы, которые могут свинью подложить
источник

AK

Anton Kazakov in ReactiveX - русскоговорящее сообщество
Я делаю запросы в сеть в интеракторе где как раз после ретрофита несколько флетов а потом возвращение обсервабала
источник

AK

Anton Kazakov in ReactiveX - русскоговорящее сообщество
А подписка в презентере
источник

AK

Anton Kazakov in ReactiveX - русскоговорящее сообщество
Так что наверное все будет в ио
источник

AK

Anton Kazakov in ReactiveX - русскоговорящее сообщество
Если не путаю на мобиусе был доклад и там чувак говорил что сабскрайбон один на чейн
источник

IK

Igor Komarov in ReactiveX - русскоговорящее сообщество
Anton Kazakov
Если не путаю на мобиусе был доклад и там чувак говорил что сабскрайбон один на чейн
Это да, только на момент какого из subscribe он происходит ?
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
observeOn переводит на новый поток все то, что по чейну ниже его
источник

IK

Igor Komarov in ReactiveX - русскоговорящее сообщество
Михаил
без кода непонятно. там есть операторы, которые могут свинью подложить
только цепочка flatMap-ов
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
Igor Komarov
Это да, только на момент какого из subscribe он происходит ?
в данном случае сабскрайб - это подписка на весь поток, соответственно он распостраняется на весь чейн, если не указано обратного.
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
Тоесть поток запускается на шедулере, указанном в subscribeOn (где бы он не стоял), и будет выполняться на этом шедулере до первого observerOn.
источник

IK

Igor Komarov in ReactiveX - русскоговорящее сообщество
О, супер, спасибо
источник

VB

Vitaliy Babichev in ReactiveX - русскоговорящее сообщество
И если несколько subscribeOn, то действующим становится последний. Вроде.
источник

AK

Anton Kazakov in ReactiveX - русскоговорящее сообщество
А я думал первый наоборот
источник

IK

Igor Komarov in ReactiveX - русскоговорящее сообщество
Первый вроде как, мне помнится говорили что второй типа на первом будет выполняться, нет ?
источник

AK

Anton Kazakov in ReactiveX - русскоговорящее сообщество
Нужно то видео посмотреть или почитать)
источник

А

Андрей in ReactiveX - русскоговорящее сообщество
Vitaliy Babichev
И если несколько subscribeOn, то действующим становится последний. Вроде.
Матвей вот здесь говорит что первый. https://youtu.be/9Y6EZPxXxYk?t=1133
источник

A

Abripuit in ReactiveX - русскоговорящее сообщество
Действующий первый
источник