RxJava（Kotlin）、Observable.ambとPublishSubjectは発砲していません

Question

15秒間隔で、または被験者refreshEventsSubjectにonNextを発射したときはいつでも、しかし成功することはありません。

対象はそう

private val refreshEventsSubject = PublishSubject<Long>()

のように開始され、そして、我々は、我々は間隔からイベントごとに15秒を取得し、この

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

のようにそれを観察してみたが、対象実行後に発砲していない

refreshEventsSubject.onNext(0)

感謝しています。

（すべてはKotlinで書かれている）

Answer 1

は、それがデッドロックを引き起こす可能性としてrefreshEventsSubject.onNext(0)があなたのメインスレッドから呼び出されていないことを確認してください！

マージではなくhttp://reactivex.io/documentation/operators/amb.htmlも使用してください。マージでは、被験者のonNextを呼び出す2つのイベントが発生します。

Answer 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