code6.kt

fun <T> Observable<T>.debounceIf(
    ...
): Observable<T> {
    return Observable.merge(
        debounce(timeout, unit, scheduler)
            .filter { predicate(it) },      // The first stream
        filter { !predicate(it) }          // The second stream
    )
}