android - RxJava(Kotlin)、Observable.amb 和 PublishSubject 未触发

Question

我们正在尝试观察 15 秒的间隔，或者每当我们发射 onNext 时关于我们的主题 refreshEventsSubject , 但没有成功。

主题是这样发起的

private val refreshEventsSubject = PublishSubject<Long>()

然后我们试着这样观察它

Observable.merge(Observable.interval(0, 15, TimeUnit.SECONDS), refreshEventsSubject) .subscribe { ... }

我们每 15 秒从间隔中获取事件，但主体在运行后没有开火

refreshEventsSubject.onNext(0)

任何想法表示赞赏。

(一切都用 Kotlin 编写)

Answer 1

确保 refreshEventsSubject.onNext(0) 不是从您的主线程调用的，因为它可能会导致死锁!

也可以使用 http://reactivex.io/documentation/operators/amb.html而不是合并，因为合并将发出两个事件反对在您的主题上调用 onNext。