Kotlin bind view reactive

BindViewExample.kt

fun <T> bind(lifecycle: Observable<Lifecycle>,
                 mainThreadScheduler: Scheduler,
                 state: Observable<T>,
                 viewAction: (T) -> Unit) {
        lifecycle
                .filter { CREATE }
                .switchMap { state }
                .observeOn(mainThreadScheduler)
                .takeUntil(lifecycle.filter { DESTROY })
                .subscribe(viewAction)
    }

    fun bindData(lifecycle: Observable<Lifecycle>) {
        fun <T> bindSimple(state: Observable<T>, viewAction: (T) -> Unit) =
                bind(lifecycle, AndroidSchedulers.mainThread(), state, viewAction)

        bindSimple(Observable.just(1), ::action)
    }

    fun action(int: Int) {
        // do smth
    }