Size: a a a

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

2020 June 12

I

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

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
ну по Rx ты делаешь верно
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
смотри может что-то блокирует подписку
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Артем Кулик
смотри может что-то блокирует подписку
ок, а ты из RxJS?
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
я на сервере юзаю RxJava
источник

АК

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

I

Ivan in ReactiveX - русскоговорящее сообщество
Артем Кулик
я на сервере юзаю RxJava
Аааа, понял
источник

EG

Evgeny GooDi in ReactiveX - русскоговорящее сообщество
в чем может быть причина - ни один лог не выводится. по точкам - тоже не заходит никуда. никак не пойму что не так
источник
2020 June 13

I

Ivan in ReactiveX - русскоговорящее сообщество
Evgeny GooDi
в чем может быть причина - ни один лог не выводится. по точкам - тоже не заходит никуда. никак не пойму что не так
Мб с дао что не так
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Evgeny GooDi
в чем может быть причина - ни один лог не выводится. по точкам - тоже не заходит никуда. никак не пойму что не так
Судя по всему апдейт плейлист не завершается
источник
2020 June 15

Т

Тони in ReactiveX - русскоговорящее сообщество
Друзья, подскажи советом:

Есть  hash map (ключ - значение)

Нужно создать цепочку последовательных вызовов.

Например если размер мапы 10 -> то нужно 10 раз сделать какое-либо действие причем последовательно.
Как это можно реализовать?
источник

EG

Evgeny GooDi in ReactiveX - русскоговорящее сообщество
Тони
Друзья, подскажи советом:

Есть  hash map (ключ - значение)

Нужно создать цепочку последовательных вызовов.

Например если размер мапы 10 -> то нужно 10 раз сделать какое-либо действие причем последовательно.
Как это можно реализовать?
hashmap.map{.  } ?
источник

Т

Тони in ReactiveX - русскоговорящее сообщество
 val obs = Observable.fromArray(values)

       obs.flatMap { users -> Observable.fromIterable(users) }
           .subscribe {
//do request
}

Поидее этот код то что мне нужно ?
источник

EG

Evgeny GooDi in ReactiveX - русскоговорящее сообщество
Похоже на правду
источник

Т

Тони in ReactiveX - русскоговорящее сообщество
А мы можем быть уверены что в коде выше - мы прям дожидаемся когда выполнится первое действие и перейдем ко второму?
источник

EG

Evgeny GooDi in ReactiveX - русскоговорящее сообщество
Так можно проверить
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Тони
 val obs = Observable.fromArray(values)

       obs.flatMap { users -> Observable.fromIterable(users) }
           .subscribe {
//do request
}

Поидее этот код то что мне нужно ?
Почитай про разницу между flatMap, concatMap и switchMap
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
// do request обычно Single, если только речь не о первой rx Java, а потому есть разница
источник

АК

Артем Кулик... in ReactiveX - русскоговорящее сообщество
Ребят, я тут короче наколякал прикольную ORM основанную на RxJava для написания асинхронного кода. С элементарным примером и базовым CRUD функционалом. Пока только для MySQL.  
Хочу и дальше ее саппортить и продвигать. Если кому интересно, то можете написать в личку и дам линк на гитхаб)
Дальше собираюсь ее наращивать, а в дальнейшем релизнуть и фреймворк для REST сервисов также на RxJava.
Крч, стучитесь=) Пока стыдно сюда давать линк, надо ее немного отретушировать)
источник

v

vitaly in ReactiveX - русскоговорящее сообщество
почему запрос, который в зипВиз делается до того, как вызовется верхний конкатМап? Как оно вообще работает?
источник