I
да, действительно, спасибо
Size: a a a
2021 June 11
I
не знал, сапсибо
I
вот тут не понял.
subscribeOn же влияет на весь апстрим
subscribeOn же влияет на весь апстрим
l
нет, только на то что сверху, до первого шедулера
AI
только на начало операции, т.е. в данном случае код getItems будет выполняться на Schedulers.single(), и затем debounce перебросит его на Computation. Если надо перебросить эммит на другой поток, то нужен observeOn
I
благодарю.
теперь всё ясно
теперь всё ясно
A
Кстати, а в этом случае координация происходит на каком потоке?
A
По идеи на single должна.
2021 June 17
IL
Как можно подключиться к вебсокету? Есть статьи?
R
Насчёт статей не знаю, однако можно посмотреть в сторону publishsubject. Все очень просто. Используешь api сокета и при новых данных эмитиш их в нужный обсервабл.
R
Это мысль навскидку))
SM
Друзья, помогите, уже несколько часов бьюсь и никак не могу понять как мне выполнить Transaction запрос в Room с помощью RxJava в бэкграунд потоке
Я пробовал устанавливать разные Completable, функциям и методам, пробовал
Я пробовал устанавливать разные Completable, функциям и методам, пробовал
Observable.just(retailersSearchHistoryDatabase.insert(id)) .observeOn(Schedulers.newThread()) .subscribeOn(Schedulers.newThread())Но ничего не получается. Подскажите, пожалуйста, каким образом мне решить эту проблему
.subscribe()
RC
Там есть готовый адаптер room-rxJava, можно сразу из dao возвращать Observable и прочие обертки
И
замените just на Completable.fromAction - observable тут не нужен, а вообще да выше написали - есть готовое решение, смысл свое делать. Ну и советую погуглить про just и потоки
2021 June 18
NK
Ну екарный бабай, и кого из вас банить?
MT
а что, нужно что-то написать? 😁
NK
Да нет, по виду не боты вроде все, толпой зашли видимо откуда-то
MT
да. в ангуляр-группе кто-то спросил ссылку на отдельный рхжс канал. видимо, оттуда. но я оттуда.
NK
так кучно обычно ботов накидывают
MT
ну у всех в общих подписках со мной висит angular - значит, 99% оттуда 😁