Почему подписка называется дважды в цепочке Rx? - PullRequest
Новая
       19

Почему подписка называется дважды в цепочке Rx?

0 голосов
/ 22 апреля 2020

Вот фрагмент кода 

 mDisposables.add(
                request.perform()
                    .map(it ->
                        {
                            Log.i("test", "map");
                            return it;
                        })
                        .observeOn(mMainScheduler)
                        .subscribe(data ->
                                { 
                                  Log.i("test", "subscribe");
                                  setData(data);
                                }
                        ));

, а perform() содержит Flowable.combineLatest

Итак, что произошло, так это то, что карта и подписка вызываются дважды, но комбинируются по последнему слову, когда регистрируются следующие путь. map subscribe combinelatest map subscribe

Мне интересно, почему map и подписка вызываются дважды, а первый раз происходит после comblatest?

...