Size: a a a

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

2021 March 25

XL

Xander L in ReactiveX - русскоговорящее сообщество
оператор
источник

XL

Xander L in ReactiveX - русскоговорящее сообщество
тут нужно смотреть варианты
источник

XL

Xander L in ReactiveX - русскоговорящее сообщество
в зависимости от того, как и кгда и какие значения выкидывают оба потока
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
zip будет прерывать выполнение если один из них тровнит ошибку
источник

XL

Xander L in ReactiveX - русскоговорящее сообщество
так ты отлови ошибку, и прокинь значение с ошибкой дальше
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
оно в блок красный даже не заходит после 1
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
в блок верхний ерор заходит
источник

XL

Xander L in ReactiveX - русскоговорящее сообщество
Если в блок верхни не заходит, ошибка гдето тут
источник

XL

Xander L in ReactiveX - русскоговорящее сообщество
источник

l

lenar in ReactiveX - русскоговорящее сообщество
Grzegorz `gzhegow` PHP / JS
пока остается загадкой, - если хттп запрос является приказом "получить новые данные с сервера в уже существующий поток" - что будет если упомянуть этот поток где-то - ведь выполнится запрос за данными, придут новые, и стало быть все подписчики которые были отработают еще раз. то есть очень условно здесь есть возможность запилить вечный цикл, когда мы хотели узнать что в потоке, сделали на него свитчмап, он под капотом сходил на сервер, получил там данные, чем вызвал пополнение самого себя и все обработчики, которые запустили процесс заново и ушли в блокировку ивентлупа

чтобы сделать такое на промизах нужно было реально написать function get() { return Promise.then(get); }

а здесь такое можно сделать неявно, подписавшись чуточку не туда. либо же все держится на том, что обьект потока никогда не возвращается, а возвращается только чертеж по его созданию, что исключает возможность случайно подписаться на уже существующий и вызвать нежелательный сайд эффект.
> чтобы сделать такое на промизах нужно было реально написать function get() { return Promise.then(get); }

я сейчас тебя обрадую, но в реактивщине это не рекурсия будет. хотя выглядит как рекурсия 🙂
источник

l

lenar in ReactiveX - русскоговорящее сообщество
Observable<Integer> getObs() { return Observable.range(1,10).concatWith(Observable.defer(() -> getObs())); }
источник

GP

Grzegorz `gzhegow` P... in ReactiveX - русскоговорящее сообщество
lenar
Observable<Integer> getObs() { return Observable.range(1,10).concatWith(Observable.defer(() -> getObs())); }
то есть он все таки создает новый поток каждый раз когда наткнется на него в обработчике
источник

l

lenar in ReactiveX - русскоговорящее сообщество
Grzegorz `gzhegow` PHP / JS
то есть он все таки создает новый поток каждый раз когда наткнется на него в обработчике
нет. он может как создать, так и не создать. управление идеи через подписку, снаружи
источник
2021 March 26

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
Я заметил что мерж не совсем паралельно все стартует
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
Запрос из задержкой в 2 секунды, и мерж на идёт дальше пока не прийдёт ответ из сети
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
А хотя мб и паралельно просто я не вижу этого 🤣
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
Просто как по мне, запись в бд, будет быстрее чем поход в сеть
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
А первый приходит ответ из сервера
источник

XL

Xander L in ReactiveX - русскоговорящее сообщество
источник

AM

Artem Mi in ReactiveX - русскоговорящее сообщество
Тип, кто первый вошёл, тот первый и шлёт ответ ?
источник