Операторы RxJava для Kotlin Coroutines, использующие throttleLatest, differentUntilChanged

Question

Как лучше всего преобразовать эту цепочку RxJava в Kotlin Coroutines?

RxTextView
    .textChanges(inputEditText)
    .map { it.toString() }
    .throttleLatest(500, TimeUnit.MILLISECONDS, true)
    .distinctUntilChanged()
    .subscribe({ text ->
        // More logic here
    }, { error ->
        // Error handling
    })