rxjavafx_backpressure_typing.kt

/* Include these Gradle dependencies
compile 'no.tornado:tornadofx:1.5.4'
compile 'com.github.thomasnield:rxkotlinfx:0.1.4'
compile 'io.reactivex:rxkotlin:0.60.0'
*/

class MyView : View() {

    val items = FXCollections.observableArrayList("Alpha","Beta","Gamma",
            "Delta","Epsilon","Zeta","Eta")

    override val root = vbox {

        val listView = listview(items)
        val typeLabel = label {
            style {
                fontSize = 20.px
                textFill = Color.RED
            }
        }

        val burstyMulticast = listView.events(KeyEvent.KEY_TYPED).publish().refCount().map { it.character }

        burstyMulticast.throttleWithTimeout(500, TimeUnit.MILLISECONDS).startWith("")
                .doOnNextFx { typeLabel.text = "" }
                .switchMap {
                    burstyMulticast.scan { x,y -> x + y }
                            .doOnNextFx { typeLabel.text = it }
                            .switchMap { input ->
                                items.toObservable()
                                        .filter { it.toUpperCase().startsWith(input.toUpperCase()) }
                            }
                }.observeOnFx().subscribe { listView.selectionModel.select(it) }
    }
}