Публикации по теме 'reactivex'


Обработка наблюдаемых потоков с помощью наблюдаемых, подписчиков и операторов RxJS
Обзор RxJS При разработке промышленных систем крайне важно, чтобы мы строили с учетом производительности. Асинхронная неблокирующая обработка стала неотъемлемой частью экосистемы JavaScript как на стороне сервера, так и на стороне клиента. Таким образом, существует множество инструментов для помощи в разработке приложений, настроенных для обработки асинхронных задач или событий, таких как обратные вызовы, обещания, async / await и RxJS. В этом посте мы рассмотрим RxJS на высоком..

Вопросы по теме 'reactivex'

Почему в реактивных расширениях .NET не рекомендуются темы?
В настоящее время я занимаюсь фреймворком Reactive Extensions для .NET и прорабатываю различные вводные ресурсы, которые нашел (в основном http://www.introtorx.com ) Наше приложение включает в себя несколько аппаратных интерфейсов, которые...
36418 просмотров
schedule 06.03.2022

groupBy, фильтр и утечка памяти в Rx
Согласно документации groupBy : Примечание. GroupedObservable будет кэшировать элементы, которые он должен выдать, до тех пор, пока он не будет подписан. По этой причине, чтобы избежать утечек памяти, вы не должны просто игнорировать те...
1204 просмотров

Почему мой RxJava Observable не излучает или не завершает работу, если он не блокируется?
Задний план У меня есть несколько RxJava Observables (либо сгенерированных из клиентов Джерси, либо заглушек с использованием Observable.just(someObject) ). Все они должны выдавать ровно одно значение. У меня есть компонентный тест, который...
4638 просмотров
schedule 01.02.2023

RxJava — почему исполнители используют только один поток
Я создал фиксированный пул потоков для обработки события, испускаемого за 300 миллисекунд, и предположил, что процессу требуется 1000 миллисекунд. Предположим, что многопоточность будет работать, но повторно используется только один поток. Если я...
1029 просмотров

Как можно приостановить Observable без потери испускаемых элементов?
У меня есть Observable , который испускает тики каждую секунду: Observable.interval(0, 1, TimeUnit.SECONDS) .take(durationInSeconds + 1)); Я хотел бы приостановить этот Observable, чтобы он перестал выдавать числа, и возобновить его по...
4790 просмотров
schedule 10.11.2022

Создайте наблюдаемый ReactiveX в Java 6 без лямбда-выражения
Я нашел пример того, как создать наблюдаемый объект (ReactiveX): static Observable<Integer> getDataSync(int i) { return Observable.create((Subscriber<? super Integer> s) -> { // simulate latency...
912 просмотров
schedule 05.09.2023

Объединение двух наблюдателей уведомлений в RxSwift
У меня есть этот фрагмент кода: let appActiveNotifications: [Observable<NSNotification>] = [ NSNotificationCenter.defaultCenter().rx_notification(UIApplicationWillEnterForegroundNotification),...
10366 просмотров
schedule 26.06.2023

Игнорирование/фильтрация ноль
Есть ли оператор, который может фильтровать nil ? Самое близкое, что я нашел, это решение, упомянутое здесь: https://github.com/ReactiveX/RxSwift/issues/209#issuecomment-150842686 Соответствующий отрывок: public protocol OptionalType {...
8803 просмотров
schedule 09.06.2023

Сколько времени ушло на запуск Observable с использованием RxJava (ReactiveX)?
Я использую java ReactiveX (RxJava) в scala Play Framework 2.5 для асинхронной связи с кушеткой. Я хотел бы знать, сколько времени потребовалось для запуска моего наблюдаемого? Я определяю свою наблюдаемую, используя приведенный ниже код. def...
1417 просмотров

Получение начальной эмиссии Observable позже в его дереве
Дан горячий Observable<String> myObservable , который выдает значения через неравные промежутки времени. Я хотел бы иметь возможность flatMap и obs1 Observable , и в зависимости от результата obs1 я хочу flatMap и obs2 с начальным...
62 просмотров

Как использовать forkJoin Observable с собственным событием
Я использую Subject of reactivex в своем приложении angular2, чтобы сигнализировать о событии. Когда я делаю что-то подобное: let subject1 = new Subject<string>(); let subject2 = new Subject<string>();...
419 просмотров
schedule 26.09.2022

RxJava retryWhen и onError
Я начинаю разрабатывать с использованием rxJava, и у меня есть следующая ситуация: У меня есть наблюдаемое, и я хочу, чтобы один подписчик обрабатывал ошибку onError , а другой подписчик обрабатывал retryWhen . Повторная попытка проглотить...
521 просмотров
schedule 06.09.2022

RxSwift: получать события немедленно, если последнее событие не было обработано в течение определенного интервала.
Впервые в RxSwift / Reactivex. В основном то, что я пытаюсь сделать, - это вызывать сервер всякий раз, когда что-то происходит, но следить за тем, чтобы это происходило не чаще, чем каждые 10 секунд. Если возможно, реже. Например, всякий раз,...
274 просмотров
schedule 24.07.2023

RxJava Наблюдаемое минимальное время выполнения
У меня есть Observable (который получает данные из сети). Проблема в том, что observable может быть быстрым или медленным в зависимости от состояния сети. Я показываю виджет прогресса, когда выполняется наблюдаемое, и скрываю его, когда...
2376 просмотров
schedule 30.07.2022

Как я могу асинхронно вызывать несколько наблюдаемых вызовов, но синхронно выполнять некоторые вычисления до и после этих вызовов?
Я новичок в RxJava. У меня есть несколько клиентов Jersey RxJava, которые возвращают Observables. Мне нужно сделать один вызов, чтобы получить некоторые данные, эти данные станут входными данными для моих следующих 3 вызовов. Я хочу, чтобы эти...
1415 просмотров

Проверьте, не выдает ли какой-либо подписчик исключение в RxJava.
Я пытаюсь создать реактивный слушатель RabbitMQ, который позволяет нам обрабатывать каждое сообщение с несколькими подписчиками. Мы хотим только ack отправить сообщение, когда все подписчики закончат успешно. Это моя текущая установка:...
1182 просмотров
schedule 27.03.2023

Наблюдается из лениво инициализированного поля
У меня есть этот класс. Я бы хотел, чтобы клиент этого класса получал экземпляр поля chatHub, как только chatHub назначается в обратном вызове connection.connected(() -> chatHub = connection.createHubProxy(" ChatHub")); chatHub может иметь...
662 просмотров

Rxswift + Moya + Moya-ObjectMapper Обработка ошибок
Я использую Moya и Moya-ObjectMapper с Rxswift для выполнения сетевых запросов. Мой сетевой запрос ниже. let provider = RxMoyaProvider<APIClient>() requestHospitalButton.rx_tap .withLatestFrom(hospitalCode) .flatMapLatest {...
1303 просмотров
schedule 24.08.2022

RxJava объединяет обнаруженные и не обнаруженные наблюдаемые объекты
У меня есть две наблюдаемые: Наблюдаемый O (открытый): файл с некоторым содержимым, открытым в текстовом виде. Наблюдаемый E (редактировать): содержимое файла редактируется в текстовом виде Я хочу отменить наблюдаемое E и объединить его с...
844 просмотров
schedule 03.07.2022

RxJS/ReactiveX Правильная связь модулей
Я новичок в реактивном программировании, но уже влюблен. Однако все еще трудно переключить мой мозг на это. Я стараюсь следовать всем рекомендациям, таким как «Избегайте использования тем» и «Избегайте нечистых функций» и, конечно же, «Избегайте...
73 просмотров