3

15 秒間隔、またはonNextsubjectrefreshEventsSubjectに発砲するたびに観察しようとしていますが、成功していません。

主題はそのように開始されます

private val refreshEventsSubject = PublishSubject<Long>()

そして、このように観察しようとします

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

15秒ごとに間隔からイベントを取得しますが、実行後にサブジェクトが発砲していません

refreshEventsSubject.onNext(0)

どんなアイデアでも大歓迎です。

(すべてKotlinで書かれています)

4

2 に答える 2

1

refreshEventsSubject.onNext(0)デッドロックが発生する可能性があるため、メイン スレッドから呼び出されないようにしてください。

また、マージではなくhttp://reactivex.io/documentation/operators/amb.htmlを使用してください。

于 2016-11-17T17:21:24.800 に答える