3
ответа
RxJava Как заставить наблюдателей обрабатывать в порядке [дублировать]
У меня есть прецедент, когда мне нужно подписать наблюдателей A и B к наблюдаемому, но я хочу, чтобы A выполнялось до B. Я понимаю, что в зависимости от порядка подписки не рекомендуется, поэтому я был ...
вопрос задан: 8 May 2014 07:26
2
ответа
Почему этот список разных наблюдаемых RxPY всегда излучает одно и то же? [Дубликат]
Используя понимание списка, я создал список из 10 различных наблюдаемых. Однако они всегда печатают одни и те же вещи («ticker_9»), несмотря на то, что их тайминги различны. из __future__ import ...
вопрос задан: 4 May 2012 22:58
1
ответ
rxjava завершено после повторной попытки при завершении
Я использую оператор retryWhen на Completeable, есть ли способ сказать, что это завершено от повторной попытки Flowable? что-то вроде этого - PublishSubject <? > retrySubject = PublishSubject.create () ...
вопрос задан: 25 February 2019 08:52
1
ответ
Буферизация RxJava - игнорирование нулевых элементов
Вот код, который у меня есть для буферизации и преобразования входящих событий: public Publisher < Collection < EventTO > > logs (String eventId) {ConnectableObservable < Event > ...
вопрос задан: 20 January 2019 04:24
0
ответов
Каковы гарантии параллелизма для Flowable.merge ()
Я подробно изучил документацию оператора RxJava Flowable.merge (), но не могу найти нужную мне информацию. Мое понимание, после некоторых экспериментов, это то, что дано вверх по течению ...
вопрос задан: 7 March 2019 10:55
0
ответов
Выделенные потоки ReactiveX и синглы не выделяют элементы
Я тестирую некоторые функции, основанные на RxJava, используя Mockito, чтобы имитировать объекты. У меня есть место, где мне нужно высмеять значение для возвращаемого метода, который является Single & lt; HttpResponse & lt; Buffer & gt; & gt; & gt; но .
вопрос задан: 13 July 2018 11:25
0
ответов
Как сделать, чтобы Наблюдаемый Интервал стартовал немедленно, без задержки?
Я хочу, чтобы моя наблюдаемая запускалась немедленно, и снова каждую секунду. Интервал не будет срабатывать сразу. Я нашел этот вопрос, который предложил использовать startWith, который немедленно срабатывает, но потом я получаю ...
вопрос задан: 24 May 2017 18:19
0
ответов
Наблюдение UITextField.editing с помощью RxSwift
Я хочу наблюдать за свойством UITextfield.editing. Я использую этот код: self.money.rx_observe (Bool.self, "edit"). SubscribeNext {(value) in print ("")} .addDisposableTo (disposeBag) Но в ...
вопрос задан: 22 September 2016 08:02