Size: a a a

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

2020 September 02

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
по идее ты должен получать только последний элемент после подписки
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
хотя по разу коллбэки всё-таки должны вызваться?
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
ну или действительно программа останавливается сразу после подписки
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Почему нельзя concatMap вызывать у Single?
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
да получаю я элемент, получаю, дело не в элементе, а в том, что коллбеки не работают
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
а в логах какой вывод в итоге?
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
блин, я туплю
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
у тебя очевидная проблема на самом деле
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
ты подписываешься на сабджект без коллбэков
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
нужно либо подписку прицепить к коллбэкам, либо обновлять subject переменную на новый сабджект с коллбэками
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
lenar
потому что твои три оператора это новый поток. а подписываешься ты на исходный
ну вот в принципе сразу тебе ответили
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Dmitry Upovalov
а в логах какой вывод в итоге?
Дак я про это тоже сказал. Запусти код и увидишь
источник

S

Singular in ReactiveX - русскоговорящее сообщество
зачем гаадть
источник

l

lenar in ReactiveX - русскоговорящее сообщество
там аж три проблемы. ту что я описал, вторая что события раньше подписки и третья что main может завершится раньше (это зависит от того на каких потоках выполнения все эти стримы)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Ладно задам вопрос по другому.
Observable.concat выдает источник, а concatMap выдает сразу результат, как быть?
У меня 2 источника Single
источник

l

lenar in ReactiveX - русскоговорящее сообщество
конверти в обсы. в чем проблема?
источник

DU

Dmitry Upovalov in ReactiveX - русскоговорящее сообщество
Singular
зачем гаадть
я то уже разобрался. пиши автору вопроса )
источник

l

lenar in ReactiveX - русскоговорящее сообщество
и использую статик, раз у тебя на руках стримв
источник

S

Singular in ReactiveX - русскоговорящее сообщество
lenar
конверти в обсы. в чем проблема?
Не слишком жирно
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Singular
Ладно задам вопрос по другому.
Observable.concat выдает источник, а concatMap выдает сразу результат, как быть?
У меня 2 источника Single
Что скажите?
источник