Какой набор операторов RxJava можно использовать для объекта PublishSubject, который задерживает все элементы, кроме первого, а затем пропускает все элементы, кроме последнего, во время задержки?

Question

Я пытаюсь создать последовательность RxJava для объекта PublishSubject, который имеет следующие свойства:

1. Абонент получает первое значение без задержки.
2. Все последующие значения задерживаются на 1 секунду после предыдущей доставки подписчику.
3. Если в течение этого времени наблюдается значение> 1, все, кроме последнего, отбрасываются.

Мраморная диаграмма будет выглядеть так:

1   2   3   4   5       2   3   4

< ----- 1 second ------><--- 1 second ----->

1                       5                   4

Answer 1

Получается throttleLatest - это то, что я искал.