Extension method on Observable

Observable.kt

fun <T> Observable<T>.debounceIf(predicate: (T) -> Boolean, delay: Long, unit: TimeUnit): Observable<T> {
    return this.debounce {
        when {
            predicate(it) -> Observable.timer(delay, unit)
            else -> Observable.empty()
        }
    }
}