15 秒間隔、またはonNext
subjectrefreshEventsSubject
に発砲するたびに観察しようとしていますが、成功していません。
主題はそのように開始されます
private val refreshEventsSubject = PublishSubject<Long>()
そして、このように観察しようとします
Observable.merge(Observable.interval(0, 15, TimeUnit.SECONDS), refreshEventsSubject)
.subscribe { ... }
15秒ごとに間隔からイベントを取得しますが、実行後にサブジェクトが発砲していません
refreshEventsSubject.onNext(0)
どんなアイデアでも大歓迎です。
(すべてKotlinで書かれています)