Как я могу изменить продолжительность окна во время выполнения для throttleFirst RxJava - PullRequest
Новая
       55

Как я могу изменить продолжительность окна во время выполнения для throttleFirst RxJava

0 голосов
/ 24 декабря 2018

Можем ли мы изменить время windowDuration во время выполнения на основе условия if-else.Ex.Предположим, что если условие истинно, то время окна равно 5 секундам, а условие ложно, тогда время окна равно 10 секундам. 

publishSubject = PublishSubject.create<Any>()
    disposable = publishSubject
            ?.throttleFirst(windowDuration, unit)
            ?.subscribeOn(Schedulers.computation())
            ?.observeOn(AndroidSchedulers.mainThread())
            ?.subscribe {
                receiver.onReceive(it)
            }
    /**
    * Sending object at every miliseconds
    */
    fun send(any: Any) {
        publishSubject?.onNext(any)
    }

Пожалуйста, предложите любой способ или способ сделать это.Любая помощь будет заметна с моей стороны.Спасибо.

...