我们_59188_在我们的主题 refreshEventsSubject 上重新开始 onNext ，但没有成功 .
主题是这样开始的
private val refreshEventsSubject = PublishSubject<Long>()
然后我们试着像这样观察它
Observable.merge(Observable.interval(0, 15, TimeUnit.SECONDS), refreshEventsSubject) .subscribe { ... }
我们每隔15秒从间隔中获取事件，但是在运行后主体没有触发
refreshEventsSubject.onNext(0)
任何想法都赞赏 .
（一切都写在Kotlin）
2 回答
阅读AMB的文档：http://reactivex.io/documentation/operators/amb.html
具体
emit all of the items from only the first of these Observables to emit an item or notification.您正在寻找的运营商可能是
Observable.merge：http://reactivex.io/documentation/operators/merge.html确保未从主线程调用
refreshEventsSubject.onNext(0)，因为它可能导致死锁！也可以使用http://reactivex.io/documentation/operators/amb.html而不是合并，因为合并会在您的主题上发出两个调用onNext的事件 .