У меня есть база данных с табличным контактом, и я хочу проверить, есть ли контакт с каким-либо номером телефона. @Query("SELECT * FROM contact WHERE phone_number = :number") Flowable<Contact> findByPhoneNumber(int number); У меня есть...

Я новичок в реактивеХ. Я включил rx-android в свой проект, добавив в файл модуля gradle следующие строки: compile 'io.reactivex.rxjava2:rxandroid:2.0.1' compile 'io.reactivex.rxjava2:rxjava:2.1.7' и теперь я пытаюсь начать использовать его....

У меня есть Observable, который испускает целые числа: Observable.just(1, 2, 3, 4) который будет излучать 1,2,3,4 Как я могу применить функцию, которая работает с последними n выбросами, например (псевдокод) Observable.just(1, 2,...

Мне интересно, будет ли Schedulers.io() выполнять задачи в порядке вызывающего абонента. public class SaveTest { @Inject private MyRepository myRepository; public void save() { Observable.range(0, 20)...