Extension of Observable to delay every succeeding emission

ObservableDelay.kt

fun <T> Observable<T>.delaySucceeding(interval: Long, timeUnit: TimeUnit): Observable<T> {
    return Observable.merge(
        this.take(1),
        this.skip(1).delayEach(interval, timeUnit)
    )
}

private fun <T> Observable<T>.delayEach(interval: Long, timeUnit: TimeUnit): Observable<T> {
    return Observable.zip(
        this,
        Observable.interval(interval, timeUnit),
        BiFunction { item, _ -> item }
    )
}