Я довольно новичок в RxJava, поэтому прошу прощения, если это слишком простой вопрос ... потому что язык немного отличается от того, к которому я привык, я нахожу свой обычный Google-вокруг-пока-выПодход "найти ответ" тоже не работает :)
В любом случае, вопрос к вопросу: как я могу спроектировать поток так, чтобы часть кода выполнялась только после действий пользователя (какэто происходит через мой API) остановился на X секунд? Моя цель - начать вызов нижестоящего API, но только после того, как пользователь «отключился» и перестал отправлять мне данные.
Мой мозг, не реагирующий на это, хочет получить ConcurrentHashMap<UserId, Instant>, который яобновляется по мере ввода данных пользователем, а затем поток, который просыпается каждые 5 секунд, чтобы проверить значения, которые превышают X секунд назад.