У меня PublishSubject<Event> . При каждом новом событии я инициирую запрос к базе данных (некоторые данные в локальном кэше), затем беру результат и пытаюсь выполнить POST через запрос HTTP на сервер, когда этот сервер отвечает 200 ,...

На самом деле я создал конфигурацию типа RxSearch. В котором я прикрепил Edittext textChangeListener с PublishSubject. Использование событий для отправки символов в Observable, который используется в качестве входных данных для вызова...