Описание тега publishsubject

Вопросы с тегом
1 ответ

RXJava2 управлять подписками

Мне нужно уточнить, каков наилучший подход к управлению конкретным сценарием с использованием RxJava2 (на этом основана вся структура приложения): В моем приложении многие люди могут вносить изменения в один и тот же документ, поэтому я должен предо…
31 янв '18 в 22:38
0 ответов

RXJava 2x отписаться от PublishSubject

Я пытаюсь преобразовать пример PublishSubject от Rx v1x до v2x. У меня есть следующее, но когда я звоню dispose(), onNext() продолжает срабатывать (как и ожидалось, как на примере), но вывод также продолжает выводиться на стандартный вывод. Оригинал…
14 июн '17 в 12:29
1 ответ

onNext() никогда не вызывается для PublishSubject

Я пытаюсь построить презентатор, который вычисляет некоторые события за определенный период времени, показывает загрузку только при первой загрузке и обновляет пользовательский интерфейс, когда это будет сделано. Поскольку события могут обновляться …
05 авг '17 в 02:09
1 ответ

RxBus: отправка общих событий

У меня есть общий Event класс, который я хочу опубликовать на PublishRelay это действует как мой автобус. Я хочу сделать мой RxBus отправлять события общего типа, но сама шина не является общей. Можете ли вы дать мне идеи о том, что мне нужно измени…
12 июн '17 в 11:55
0 ответов

PublishSubject в RxJava/RxAndroid вызывает сбой onError и пропускает onNext

У меня есть такой код: Процесс X: getLocationObservable() // ---> async operation that fetches the location. // Once location is found(or failed to find) it sends it to this filter : .filter(location -> { --- Operation A --- after finishing th…
24 июн '18 в 07:21
1 ответ

RxJava - как остановить публикацию PublishSubject, даже если вызывается onNext()

У меня есть взгляд, в котором я звоню следующее: // class member var myPublishSubject = PublishSubject.create<SomeObservable>() // later on in the class somewhere: while(true){ myPublishSubject.onNext(someObservable) } Я хотел бы остановить эм…
25 янв '19 в 01:43
1 ответ

Почему onSubscribe не работает в rxjava?

Когда я запускаю код ниже, если я не пишу observeOn линия, приложение вылетает, потому что getView().showBlockLayout(isBlock); вызовите метод, который пытается скрыть или показать макет. но я попытался изменить ниже observeOn(AndroidSchedulers.mainT…
20 июн '17 в 13:05
1 ответ

Использование области с PublishSubject

Я хочу отобразить результаты своей области в неизменяемую модель представления, и я хочу прослушать изменения результатов, поэтому я отправляю их PublishSubject. Однако данные не отображаются в моем окне повторного просмотра, пока я не поверну устро…
05 сен '18 в 21:26
1 ответ

RxSwift запускает наблюдаемое выполнение

У меня есть Subject наблюдаемый, представляющий результат сетевого запроса, который должен быть доставлен нескольким подписчикам. я могу использовать ReplaySubject буфера 1 и publish() метод. Однако сетевой запрос выполняется только один раз. Я хоте…
26 апр '18 в 12:49
0 ответов

Повторять, когда rxJav -> rxJava2

Я нашел примеры с повтором когда здесь @NonNull private final PublishSubject<Void> updateSubject = PublishSubject.create(); private void load() { repository .getSomething() .repeatWhen(repeatHandler -> repeatHandler.flatMap(nothing -> up…
03 апр '18 в 04:23
1 ответ

Далее не вызывается для PublishSubject в Android, rxjava?

Я использую rxjava 2 и пытаюсь использовать rxbus для передачи значения код rxbus public class SeasonTabSelectorBus { private static SeasonTabSelectorBus instance; private PublishSubject<Object> subject = PublishSubject.create(); public static…
07 май '18 в 08:47
1 ответ

Наблюдаемый со значением LastFrom

Я реализовал псевдооператор с именем "FilterByLatestFrom" в качестве функции расширения для kotlin. Я написал следующий код, используя этот оператор: fun testFilterByLatestFromOperator(){ val observableA : Observable<Int> = Observable.fromArra…
17 ноя '17 в 09:58
1 ответ

RxSwift: привязка PublishSubject к нескольким кнопкам и получение отправителя

Я работаю над приложением, которое представляет 26 (алфавит) кнопок. Прямо сейчас они все связаны с одной и той же функцией в ViewControllerчто в свою очередь вызывает другую функцию в ViewModelи, наконец, эта функция вызывает publishSubject.onNext(…
23 мар '17 в 07:47
1 ответ

Статус Asynctask && отменить эквивалент в RxJava2 Observable?

Я пытаюсь изучить RxJava2 и преобразовываю свои AsyncTasks в Observables. У меня есть следующий фрагмент кода, который я пытаюсь преобразовать. if(asyncTask.getStatus() == AsyncTask.Status.RUNNING){ asyncTask.cancel(); } asyncTask = new CustomTask()…
10 окт '17 в 18:02
0 ответов

RxJava PublishSubject не выполняется в следующем

Кто-нибудь может указать мне правильное направление, пожалуйста? У меня есть RecyclerView, который содержит ViewPager, который имеет 2 фрагмента. Таким образом, иерархия представлений выглядит примерно так: Activity -------RecyclerView -------------…
14 июл '18 в 03:57
1 ответ

RxJava: Как поддерживать Observable живым даже после получения ошибки в onError() или ReSubscribe той же Observable

На самом деле я создал конфигурацию типа RxSearch. В котором я прикрепил EditText textChangeListener с PublishSubject. Использование событий для отправки символов в Observable, который используется в качестве входных данных для вызова API модернизац…
20 дек '18 в 07:27
0 ответов

RxSwift: передать результат Single to PublishSubject Connectable Observable

У меня есть сетевой запрос, результат которого нужно распространить на нескольких подписчиков. Мой уровень API реализован как источник Single наблюдаемые, где каждый Single представляет результаты сетевого запроса. Тем не менее, я хотел бы использов…
26 апр '18 в 11:51
0 ответов

Субъект, который просто отправляет событие как уведомление, а не обязательно объект [RxJava]

У меня есть случай использования, когда я должен получить запросы из очереди. Я должен получить новый запрос, когда я закончу обработку последнего. Похоже, я должен был бы использовать Subject это может помочь мне вызвать событие после того, как я з…
09 авг '19 в 10:23
1 ответ

PublishSubject вызывает дорогостоящую функцию для всех наблюдателей

У меня есть конкретный сценарий, в котором я реализовал PublishSubject для создания элементов на основе настраиваемого события. Для каждого элемента, который будет отправлен, мне также нужно сохранить это значение (дорогостоящая операция). Я пытаюсь…
11 сен '19 в 09:47
1 ответ

RxSwift Subject не запускает событие при вызове

У меня есть приложение, использующее MVP с Coordinator шаблон. Когда детский координатор отправляет событие, я ожидаю, что AppCoordinator рекурсивно вызвать метод, который выбирает следующего координатора на основе некоторого SessionState. Основной …
08 ноя '19 в 13:02