В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

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

1015 membersпожаловаться на группу
2021 January 17

l

lenar in ReactiveX - русскоговорящее сообщество
переделай первый пример на интервал с 1 сек задержкой и в нем взять только 10 элементов (т.е. этот источник будет 10 секундным). мы увидим что первый подписчик (до connect) получит все, а второй (после sleep 3 sec), получит 7 элементов
источник
20:43пожаловаться#1

l

lenar in ReactiveX - русскоговорящее сообщество
hot = flux.interval(1 sec).take(10).publish
источник
20:45пожаловаться#2

A

Aleksandr in ReactiveX - русскоговорящее сообщество
lenar
переделай первый пример на интервал с 1 сек задержкой и в нем взять только 10 элементов (т.е. этот источник будет 10 секундным). мы увидим что первый подписчик (до connect) получит все, а второй (после sleep 3 sec), получит 7 элементов
Это всё понятно, я интересовался закономеностью эмитинга у сабскрайберов)
источник
20:52пожаловаться#3

l

lenar in ReactiveX - русскоговорящее сообщество
я не знаю о чем речь 🙂
источник
21:04пожаловаться#4
2021 January 18

AE

Alexander Evsikov in ReactiveX - русскоговорящее сообщество
Ребят, подскажите пожалуйста, как при помощи rxJava можно параллельно отправить один и тот же запрос в сеть с разными параметрами из массива параметров и смёржить ответы? Количество параметров разное, соответственно количество раз отправки запроса в сеть тоже варьируется
источник
18:29пожаловаться#5

P

Papin in ReactiveX - русскоговорящее сообщество
Alexander Evsikov
Ребят, подскажите пожалуйста, как при помощи rxJava можно параллельно отправить один и тот же запрос в сеть с разными параметрами из массива параметров и смёржить ответы? Количество параметров разное, соответственно количество раз отправки запроса в сеть тоже варьируется
если 10 параметров то 10 раз отправиться
а если 20 то 20?
источник
18:32пожаловаться#6

AE

Alexander Evsikov in ReactiveX - русскоговорящее сообщество
Papin
если 10 параметров то 10 раз отправиться
а если 20 то 20?
у запроса 1 переменный параметр, который берется из массива, количество повторений запроса зависит от количества элементов в массиве
источник
18:33пожаловаться#7

P

Papin in ReactiveX - русскоговорящее сообщество
ну есть тупой но верный способ

сначала flatMapItterable
после него .map в котором складываешь данные по своей логике которой надо
потом .toList()

сработать должно железно

НО
полюбому можно красивее без map
источник
18:37пожаловаться#8

AI

Alexey Illarionov in ReactiveX - русскоговорящее сообщество
Alexander Evsikov
у запроса 1 переменный параметр, который берется из массива, количество повторений запроса зависит от количества элементов в массиве
а чем стандартный вариант с Observable.fromArray([спискок параметров запросов]).flatmap(параметры -> запрос) не устраивает?
источник
18:39пожаловаться#9

AE

Alexander Evsikov in ReactiveX - русскоговорящее сообщество
я надеялся, что есть какой-нибудь а-ля range...
источник
18:41пожаловаться#10

AE

Alexander Evsikov in ReactiveX - русскоговорящее сообщество
всем спасибо за ответы! сделаю через fromArray
источник
18:42пожаловаться#11

P

Papin in ReactiveX - русскоговорящее сообщество
Alexey Illarionov
а чем стандартный вариант с Observable.fromArray([спискок параметров запросов]).flatmap(параметры -> запрос) не устраивает?
интересно, я никогда не юзал такое
а что на выходе будет?как смержить ответы?
источник
18:43пожаловаться#12

AI

Alexey Illarionov in ReactiveX - русскоговорящее сообщество
Papin
интересно, я никогда не юзал такое
а что на выходе будет?как смержить ответы?
смерженный поток с ответами будет. Дальше хоть .toList()
источник
18:45пожаловаться#13

АС

Александр Сергеевич... in ReactiveX - русскоговорящее сообщество
а не проще под требуемые задачи делать адекватный бэк?
источник
18:46пожаловаться#14

AE

Alexander Evsikov in ReactiveX - русскоговорящее сообщество
Александр Сергеевич
а не проще под требуемые задачи делать адекватный бэк?
проще, но не всегда получается😔
источник
18:47пожаловаться#15

AI

Alexey Illarionov in ReactiveX - русскоговорящее сообщество
Александр Сергеевич
а не проще под требуемые задачи делать адекватный бэк?
а вдруг это и есть бэк? :)
источник
18:49пожаловаться#16

АС

Александр Сергеевич... in ReactiveX - русскоговорящее сообщество
Alexey Illarionov
а вдруг это и есть бэк? :)
он сначала в андроид чате писал, не думаю)
источник
18:49пожаловаться#17
2021 January 23

A

Aleksandr in ReactiveX - русскоговорящее сообщество
Кто-нибудь сталкивался с утечками памяти при использовании горячих паблишеров?
источник
21:13пожаловаться#18
2021 January 27

Д

Денис in ReactiveX - русскоговорящее сообщество
Привет всем. Есть цепочка, как на скриншоте.  
fun getUserEntityName(peerId: Long): Maybe<String>

Как я понимаю, если getUserEntityName ничего не вернёт, то логика, описанная внутри flatMap не отработает.

Вопрос: как сделать так, чтобы отработала? )))))
источник
18:41пожаловаться#19

P

Papin in ReactiveX - русскоговорящее сообщество
onErrorResumeNext
или
odOnError
источник
18:42пожаловаться#20