Позиция OnSubscribe вызывает событие OnComplete преждевременно срабатывать

Question

Мне немного любопытно, как .subscribeOn() работает на RxJava. У меня есть этот кусок кода, который работает как задумано:

return endpoints.getRecentConversations(page) 
       .map().flatMap().doOnNext() //etc etc... 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 

Я читал this статью, пытаясь понять, в чем разница между subscribeOn и observeOn, когда эта линия привлекла мое внимание:

позиции не имеет значения

subscribeOn можно поместить в любое место в потоке, поскольку оно влияет только на время подписки

Звучит отлично. Но я чувствовал себя немного скептически, и решил проверить его. Поэтому я изменил код выше (коммутируемые линии 2 и 3):

return endpoints.getRecentConversations(page) 
       .subscribeOn(Schedulers.io()) 
       .map().flatMap().doOnNext() //etc etc... 
       .observeOn(AndroidSchedulers.mainThread()) 

В результате я получаю преждевременный onComplete() на моем подписчике. onNext() никогда не вызывается и ошибок в моем логарифме нет.

Я могу оставить вещи так, как они были, но я хотел бы знать, почему это происходит. Это правда, что позиция не имеет значения? Это что-то не так с моим кодом? Here's how my code looks

Answer 1

Да, положение имеет большое значение в RxJava, оно называется вверх по потоку & вниз по течению.

Это потому, что вы подписавшись на горячий наблюдаемый Смотреть это видео, чтобы лучше понять его: Общее RxJava Ошибка https://www.youtube.com/watch?v=QdmkXL7XikQ&t=768s

Есть два типа наблюдаемые: Горячие & холода.

А «горячий» Наблюдаемый может начать испускать элементы, как только он будет создан, и поэтому любой наблюдатель, который впоследствии присоединяется к тому, что Наблюдаемому может начать наблюдение последовательности где-то в середине. «Холодный» наблюдаемый, , с другой стороны, ждет, пока наблюдатель не подпишется на него перед ним. начинает излучать элементы, и поэтому наблюдателю гарантированно будет видеть целую последовательность с самого начала.