Я создаю рабочую очередь на основе таблицы PostgreSQL.
У меня есть Observable из INSERT событий в этой таблице. На него подписана функция, которая будет обрабатывать отдельный элемент из таблицы и удалять его из таблицы.
Работает со всеми новыми элементами, вставленными после подписки.
Поскольку таблица является постоянной, таблица может содержать элементы, о которых мы никогда не будем получать уведомления. (Например, остатки от незавершенных остановок.)
Как лучше всего решить эту проблему с RxJava?
Я видел, что есть Observable.startWith метод:
observableOfInserts.startWith(observableWithCurrentDbItems).subscribe(processSingleItem)
Я не уверен, что это правильно согласовывает то, что я хочу?