如果在最后一项之后经过了特定时间，则发出值

Question

我有一个 observable：Observable.create<Boolean> {emitter = it}，我向其推送了一些值。我希望它发布一个 'false' 值，只要某个特定时间段过去后没有任何值被推送到该发射器。

RxJava/Kotlin 2 怎么可能？

Answer 1

您可以尝试组合 2 个函数：timeout 和 onErrorReturn。

Observable.create<Boolean> { 
    // use emitter here
}
     .timeout(3, TimeUnit.SECONDS)
     .onErrorReturn { if (it is TimeoutException) false else throw it } 
     .subscribe { println("onNext $it") }

澄清后更新了代码段。 repeatWhen 将重新订阅 Observable。

Observable.create<Boolean> { 
    // use emitter here
}
    .timeout(3, TimeUnit.SECONDS)
    .onErrorReturn { if (it is TimeoutException) false else throw it }
    .repeatWhen { it }
    .subscribe { println("onNext $it") }

如果在最后一项之后经过了特定时间，则发出值

Emit value if specific time has passed after last item

java

kotlin

rx-android

rx-java2

rx-kotlin2