сохранение в db будет только при подписке на Observable, если я использую Observable.create()/fromCallable()/defer(). Это неприемлимо. Я неправильно готовлю rx? Нужно просто заюзать Subject? Или просто rx не для этого?
https://startandroid.ru/ru/blog/492-kak-obernut-metod-v-rxjava.html
Observable.fromCalleble тебя спасёт
Почему подписка не приемлема? Тут подойдет maybe. Имхо.
Или как в гуглопримерах diskIO = Executors.newSingleThreadExecutor(); ... diskIO.execute(() -> database.dao().insert(record));
Обсуждают сегодня