Я довольно новичок в RxJ и ищу способ сэмплировать / дросселировать (пока не нашел правильного слова) события из Subject следующим образом
- fastсобытия в последовательных выборках каждые
x миллисекунды y миллисекунд без событий
Мраморная диаграмма будет выглядеть как
o o o o oo o o o o
↓ ↓ ↓ ↓ ↓↓ ↓ ↓ ↓ ↓
┌─────────────────────────────────────────────────────────────┐
│ magic │
└─────────────────────────────────────────────────────────────┘
↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓
o o o o o o o o o
Какой оператор (ы)) я бы использовал для этого?К сожалению, sampleTime, debounceTime или throttleTime не дали мне правильного вывода.
Заранее извиняюсь за то, что может быть глупым вопросом / новичком.