Вопросы по теме 'reactivex'
RxJava flatMap и странное поведение обратного давления
При написании задания синхронизации данных с RxJava я обнаружил странное поведение, которое не могу объяснить. Я новичок в RxJava и буду признателен за помощь.
Вкратце, моя работа довольно проста. У меня есть список идентификаторов элементов, я...
732 просмотров
schedule
13.06.2022
Rx: Как получить последний элемент, даже если был вызван onError?
Я использую RxJava, и мне нужно сделать 2 вещи:
Получить последний элемент, испускаемый из Observable
Определите, был ли вызван onError или onCompleted
Я рассматривал использование last и lastOrDefault (на самом деле это то...
2226 просмотров
schedule
11.02.2023
Операторы RxJS groupBy и CombineAll, похоже, пропускают вывод
При группировании вывода с помощью комбинации .groupBy и .concatAll некоторые ожидаемые выходные данные не создаются.
Образец кода:
var Rx = require('rx');
var source = Rx.Observable.from(['a1', 'a2', 'b1', 'b2', 'a3', 'a4', 'b3', 'b4'])...
566 просмотров
schedule
22.12.2023
Ограничение действий с помощью оператора rxJava и retryWhen
В общем, мое приложение должно выполнять две задачи:
Одновременно принимать только один сетевой запрос
Повторить, если запрос не удался
Вот как я это реализую:
public class RequestsLocker {
private volatile boolean isLocked;...
933 просмотров
schedule
20.05.2022
Сбор неполных на данный момент наблюдаемых в наблюдаемой rxjs более высокого порядка
Например, у меня есть наблюдаемое, которое выдает 10-секундный таймер каждые 5 секунд. Я могу использовать сканирование для создания наблюдаемого, которое испускает массив всех внутренних наблюдаемых объектов, выпущенных на данный момент:
tick =...
327 просмотров
schedule
19.08.2022
Считается ли ошибка выбросом от наблюдаемого в RxJ?
Быстрый вопрос: будет ли .do() срабатывать при возникновении ошибки? В документах говорится: «Выполнять побочный эффект для каждой эмиссии в исходном Observable, но возвращать Observable, который идентичен исходному». Ошибка тоже считается...
40 просмотров
schedule
05.01.2023
Выберите элемент из массива Observable Angular
Я запрашиваю API и пытаюсь получить определенный элемент из массива, который он возвращает.
Я запрашиваю API и получаю ответ JSON. Я отправляю ответ через вызов .map функции, которая сопоставляет каждый объект в ответе с T.
getOne(num:...
517 просмотров
schedule
08.09.2023
Публикация/использование: ожидание подписки, фильтрация сообщений и удаление
Использование Rx.Net 3
С помощью планировщика Quartz.Net я создаю диспетчер рабочих процессов для цепочки заданий (используя Quartz Joblistener для готовых заданий) со встроенным веб-сервером. Приложение создает экземпляр субъекта (синглтон)....
120 просмотров
schedule
30.09.2023
Почему Buffer из моего Observable не получает события?
Я пробовал несколько способов, но не смог вызвать метод подписки:
Способ 1:
var buffer = new List<Kpi>();
buffer.ToObservable().Buffer(TimeSpan.FromMinutes(1), 5).Subscribe(
async kpis =>
{
await _retry.ExecuteAsync(() =>...
45 просмотров
schedule
19.03.2022
Как перехватывать ошибки из цепочек наблюдаемых rxjs при использовании combLatest?
Вслед за этот пост , у меня есть следующее
Observable.combineLatest(
this.translate.get("key1"),
this.translate.get(""),
this.translate.get("key3"),
this.translate.get("key4")
)
.subscribe(([result1,...
1468 просмотров
schedule
14.07.2022
RxJs Observable завершается несколько раз
Ниже приведен короткий фрагмент реактивного кода ( RxJs ).
let subj = new Rx.Subject();
let chain = subj
.switchMap(v => Rx.Observable.of(10*v).do(vv => console.log("Switch map", vv)))
.share()
.take(1);
function...
1599 просмотров
schedule
10.10.2023
Почему Rx.Observable.throw(x) на самом деле не выбрасывает?
Я играю с Rxjs, наблюдаемыми объектами и картами и обнаружил странное поведение Observable.throw(error) , которое не могу объяснить.
Если у меня есть поток Rx, который использует оператор карты, и я хочу прервать процесс, я бы ожидал, что метод...
623 просмотров
schedule
01.02.2023
Concat Observables разных типов
У меня есть сетевой вызов, который аутентифицирует и получает токен, и второй, который, используя этот токен, запрашивает данные.
Я хочу объединить их в Single<Data> . Для этого я смотрел на concat , но, похоже, это работает только для...
2496 просмотров
schedule
22.06.2023
Эквивалент RxJS switchMap в ReactiveX/Rx.NET
В RxJS есть функция switchMap . Есть ли аналог в ReactiveX/Rx.NET ? Я не вижу его в документации по преобразованию .
2379 просмотров
schedule
18.12.2022
Как условно буферизовать ввод ключа на основе события в RxJs
Я новичок в RxJs и не читал решения этой проблемы. Более подробное объяснение находится в комментариях, но в основном я хочу обработать комбинацию клавиш (я думаю, что буфер сделает это) при нажатии определенной клавиши (например, нажатие «o» будет...
586 просмотров
schedule
30.04.2024
Прогрессивная загрузка изображений с помощью ReactiveX
Я пытаюсь загрузить уменьшенное изображение предварительного просмотра , за которым следует изображение нанимает . Я хочу убедиться, что если по какой-то причине изображение нанимает будет загружено первым, изображение предварительного просмотра...
97 просмотров
schedule
12.04.2024
Нужен простой пример map() reduce() с RXJava на Android без лямбда-выражений Java 8
Я пытаюсь применить RXJava в приложении для Android без Java 8, то есть я не могу использовать лямбда-функции. В качестве теста, чтобы убедиться, что я понимаю основы, я просто хотел бы увидеть простой пример с использованием map() и reduce()....
6256 просмотров
schedule
01.03.2023
reactivex повторный пропуск между
Предположим, у меня есть следующий поток данных:
1, 2, 3, a, 5, 6, b, 7, 8, a, 10, 11, b, 12, 13, ...
Я хочу отфильтровать все между «а» и «б» (включительно), независимо от того, сколько раз они появляются. Таким образом, результатом...
27 просмотров
schedule
31.05.2022
Как я могу использовать Observables вместо обещаний?
У меня есть служба с некоторыми методами, большинство из них требуют завершения определенного обратного вызова, прежде чем он сможет выполнять свои функции. С промисами в псевдо это очень легко сделать:
ready = http.get(stuff); // Returns a...
123 просмотров
schedule
23.10.2023
Преобразование из HttpModule в HttpClientModule
Angular преобразуется из HttpModule в HttpClientModule и отказывается от первого, как подробно описано в Разница между HTTP и HTTPClient в angular 4? .
Однако в руководстве по Angular на странице https://angular.io/tutorial/toh-pt6 используется...
2370 просмотров
schedule
17.10.2023
