Size: a a a

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

2020 August 20

АК

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

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Артем Кулик
ну пермишн менеджер у вас в андрюшке тоже 1)
ну тут спорно, его скорее вообще нет)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Aleksey D.
нравится, как этот чувак задает вопрос, все бросаются ему на помощь, а он больше не появляется в чате до следующего вопроса)
;D, я вообще - то читаю)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Aleksey D.
так, пойду сам вопрос прочитаю)
Ну вопрос может быть и правда не корректный, суть такая что я вначале делаю запрос в сеть, затем получаю данные и паралельно хочу записать их в БД. Но чтобы не ждать окончания пока данные в БД запишутся, отдать их в БД, а самому в onSuccess обработать запрос из инета
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Singular
Ну вопрос может быть и правда не корректный, суть такая что я вначале делаю запрос в сеть, затем получаю данные и паралельно хочу записать их в БД. Но чтобы не ждать окончания пока данные в БД запишутся, отдать их в БД, а самому в onSuccess обработать запрос из инета
хранение в базу, в в цепочке дальше выбираешь оператор для работы со своими данными
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Только не забывай, что onSuccess синхронный, то есть тебе нужно будет в бд писать на другом потоке
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Но это не точно, в первой рх было так, я так и пишу, во второй не проверял
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Ну вот я и писал, flatMap юзать чтоли?
источник

S

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

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Singular
Но мне не хочется ничего возвращять
Можешь закомплитить
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Singular
Ну вопрос может быть и правда не корректный, суть такая что я вначале делаю запрос в сеть, затем получаю данные и паралельно хочу записать их в БД. Но чтобы не ждать окончания пока данные в БД запишутся, отдать их в БД, а самому в onSuccess обработать запрос из инета
исключительно для этого я и изобрёл цепь, которую кидал тебе выше
источник

S

Singular in ReactiveX - русскоговорящее сообщество
1) Я сделал запрос в сеть
2) получил данные в onSuccess, но перед этим я должен эти данные отправить в Completable для хранения данных. Вот и хочу узнать как код в RX должен выглядеть
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
iamthevoid
хранение в базу, в в цепочке дальше выбираешь оператор для работы со своими данными
я со стороны логики не понимаю вот,

зачем сохрнаять данные в БД в цеопчке?

зачем заставлять юзверя ждать, пока данные сохраняться? (да, это недолго вв 99%, просто идеологически не понимаю)
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Ivan
исключительно для этого я и изобрёл цепь, которую кидал тебе выше
```
.doAfterSuccess {
   anotherPublisher()
     .subscribeOn(Schedulers.io())
     .subscribe()
 }
```
Вот так?
источник

I

Ivan in ReactiveX - русскоговорящее сообщество
Singular
```
.doAfterSuccess {
   anotherPublisher()
     .subscribeOn(Schedulers.io())
     .subscribe()
 }
```
Вот так?
я делаю так, да
источник

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
Singular
Ну вопрос может быть и правда не корректный, суть такая что я вначале делаю запрос в сеть, затем получаю данные и паралельно хочу записать их в БД. Но чтобы не ждать окончания пока данные в БД запишутся, отдать их в БД, а самому в onSuccess обработать запрос из инета
да тут вообще Rx не нужен же. запись в бд - синхронная операция и падать не будет, достаточно убедиться, что doAfterNext отработает на фоновом потоке
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Ivan
я со стороны логики не понимаю вот,

зачем сохрнаять данные в БД в цеопчке?

зачем заставлять юзверя ждать, пока данные сохраняться? (да, это недолго вв 99%, просто идеологически не понимаю)
Вот поэтому я и не хочу сохранять в onSuccess а хранить данные паралельно, Спасибо, видимо другого способа нет кроме вашего.
Но почему он выглядит ужасным?))
Я думал там через zip, flatMap как - то можно было проще сделать...
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Хотя я привередлиный видимо просто)
источник

i

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

I

Ivan in ReactiveX - русскоговорящее сообщество
Singular
1) Я сделал запрос в сеть
2) получил данные в onSuccess, но перед этим я должен эти данные отправить в Completable для хранения данных. Вот и хочу узнать как код в RX должен выглядеть
если делать в одной цепочке то может быть так:

yourSingle()
.flatMapХ { сохраняешь в бд и бросаешь данные дальше }
.map { данные }
источник