Есть ли газ в RxJava?

Question

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

• Излучает элемент
• В течение установленного периода после того, как элемент был выпущен,все другие испускаемые элементы отфильтрованы

Кажется, я не могу найти тот, который соответствует этому поведению.Я посмотрел на некоторые похожие, но ни один из них не кажется правильным.

• debounce / throttleWithTimeout - испускает последний элемент в последовательности элементов, которые были выпущены с короткимпериод между ними

• sample / throttleLast, который просматривает установленные интервалы времени и испускает последний элемент в каждом интервале времени.

• throttleFirst, который просматривает установленные интервалы времени и выдает первый элемент в каждом интервале времени.Кажется, это ближе всего к тому, что я хочу, но это не совсем то же самое.

Есть ли какой-нибудь оператор RxJava, который я могу использовать, который бы соответствовал этому?Вроде бы полезный вариант использования.

Answer 1

throttleFirst было то, что я искал.Первоначально я не осознавал, потому что большая часть документации в Интернете немного не в порядке (http://reactivex.io/documentation/operators/sample.html, https://github.com/ReactiveX/RxJava/wiki/Filtering-Observables). Javadocs правильный, и где я нашел то, что искал.