RxJava – Входы клавиатуры с обратным давлением?

Вот забавная проблема RxJava.

Я хочу использовать операторы RxJava backpressure для быстрого поиска введенного ввода, когда набирается каждый символ, подобно тому, как Google делает на своей странице поиска. Я просмотрел документацию Backpressure, и я придумал это (я использую RxJavaFX / RxKotlinFX для использования JavaFX).

val myControl: Node = ... val burstyMulticast = myControl.events(KeyEvent.KEY_TYPED).publish().refCount() val burstyDebounced = burstyMulticast.debounce(200, TimeUnit.MILLISECONDS) val burstyBuffered = burstyMulticast.buffer(burstyDebounced) burstyBuffered .flatMap { it.toObservable().map { it.character }.reduce("") { x,y -> x + y } } .subscribe { println(it) } 

Это отлично работает. Если я наберу «Hello» против элемента управления, он испустит String «Привет» после 200 мс без ввода. Но если я хочу, чтобы это было действительно более отзывчивым, у меня действительно должно быть какое-то скользящее накопление для каждого ввода нажатия клавиши. Тогда мой вывод консоли должен выглядеть так:

 H He Hel Hell Hello высокоэнергетический H He Hel Hell Hello 

Это должны быть все мои выбросы, когда я набираю слово «Привет», а 200 мс определяет, сколько времени должно пройти до того, как накопление сбрасывается. Как мне это сделать?

• RxJava-Turn, наблюдаемый в Iterator, Stream или Sequence
• Как я могу условно добавить асинхронную операцию в середине потока RxJava?
• Для функции Kotlin, используемой в качестве выражения, существует ли краткий способ работы и возврата значения?
• Как уведомить Observable при завершении CountdownTimer
• RxKotlin - Single.just () не выделяется при подписке на TestSubscriber

• Как Kotlin coroutines лучше, чем RxKotlin?
• Как указать версию RxJava при использовании RxKotlin?
• Получить N последних объектов, испускаемых наблюдаемыми в RxJava2
• Rx-Kotlin ждутTerminalEvent, никогда не получающего onComplete
• Cant 'observOn' основная нить с RxKotlin

 H Hel Hello высокоэнергетический H Hel Hello 

 val burstyMulticast = events(KeyEvent.KEY_TYPED).publish().refCount().map { it.character } burstyMulticast.throttleLast(1000, TimeUnit.MILLISECONDS).startWith("") .switchMap { burstyMulticast.scan { x,y -> x + y } }.subscribe { println(it) }