onNext метод publishSubject вызывается непрерывно (в разное время, примерно за 1 миллисекунду)
И требование состоит в том, чтобы испускать этот элемент каждую 1 секунду, и данные не должны быть потеряны, значит, каждый элемент должен испускать.
publishSubject.onNext("Data1");
publishSubject.onNext("Data2");
publishSubject.onNext("Data3");
publishSubject.onNext("Data4");
publishSubject.onNext("Data5");
publishSubject.onNext("Data6");
publishSubject.onNext("Data7");
и так далее ...
См. Структуру кода для справки:
var publishSubject = PublishSubject.create<String>()
publishSubject.onNext(stateObject) // Executing at every milliseconds...
publishSubject
/* Business Logic Required Here ?? */
.subscribeOn(Schedulers.computation())
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
// Should execute at every 1 second
}
Пожалуйста, помогите, спасибо заранее,