Вопросы по теме 'reactive-extensions-js'

SignalR против реактивных расширений
SignalR — это то же самое, что и реактивные расширения? Можете ли вы объяснить, почему или почему нет?
6767 просмотров

Несколько асинхронных вызовов общедоступного API (rails+node.js или реактивный js)
Я пытаюсь сделать неблокирующие вызовы 3 общедоступным API, то есть веб-сайту A, B, C, а затем перенаправить результаты обратно в приложение rails в виде данных JSON. Я спросил, возможно ли это в node.js на другом форуме, и кажется, что да, и кто-то...
812 просмотров

Использование одного субъекта для распространения совершенно разных потоков событий через
Мне нужно проксировать все различные потоки событий через одну тему. Я придумал этот код: var mySubject, getObservable; getObservable = function (subject, eventName) { return subject .asObservable() .filter(function...
519 просмотров

RxJS относится к событиям так же, как обещания к асинхронности.
В Запрос четкого, живописного объяснения Reactive Extensions (RX)? Я спросил, что такое RX, и, думаю, благодаря предоставленным ответам у меня появилась идея. В упомянутом вопросе я процитировал предложение из...
1371 просмотров

Комбинация SignalR и Reactive
Я нашел эту маленькую жемчужину о том, как заставить SignalR и Rx работать красиво: Rx и реактивный учебник Однако, как вы могли заметить, это работает только при переходе с сервера на клиент. Кто-нибудь знает, как пойти наоборот? Я хочу,...
2081 просмотров

Отфильтровать наблюдаемое, используя значения из другого наблюдаемого
У меня есть две наблюдаемые: Наблюдаемый, представляющий список входов флажков. Наблюдаемый, представляющий поток событий, поступающих с сервера. Я хотел бы отфильтровать вторую наблюдаемую, используя значения из первой. Значения,...
19270 просмотров
schedule 15.01.2022

RxJS разделяет наблюдаемую последовательность на несколько выходных данных
Можно ли разделить один наблюдаемый поток на несколько других наблюдаемых? Мой вариант использования — это форма, которую пользователь может отправить. Действие отправки обрабатывается в наблюдаемом объекте, и в этом действии прослушивается...
6227 просмотров
schedule 04.05.2024

Создание фильтруемого списка с помощью RxJS
Я пытаюсь заняться реактивным программированием. Я постоянно использую функции массива, такие как карта, фильтрация и уменьшение, и мне нравится, что я могу манипулировать массивом без создания состояния. В качестве упражнения я пытаюсь создать...
1666 просмотров

Как загружать изображения асинхронно с RxJ и выполнять метод, когда все загружено
Я пытаюсь преобразовать свой код, основанный на обещаниях, в RxJ, но мне трудно понять Rx, особенно RxJ. У меня есть массив с путями. var paths = ["imagePath1","imagePath2"]; И мне нравится загружать изображения в Javascript var img =...
8981 просмотров
schedule 27.08.2022

Обеспечьте порядок обновления подписчиков
Есть ли способ убедиться, что порядок обновления подписчиков обеспечен? У меня есть горячая наблюдаемая, и мой первый подписчик выполняет некоторую работу по синхронизации, чтобы обновить переменную, а мой следующий подписчик затем должен...
284 просмотров

Rx.Observable.interval с разным интервалом для каждого события
У меня есть куча событий, каждое из которых должно запускаться после предыдущего с задержкой, характерной для этого события. Rx.Observable.interval дает возможность указать только один интервал. Есть ли способ предоставить разные интервалы?
1300 просмотров

Правильный способ борьбы с ошибками, возникающими в onNext для горячих, общих, наблюдаемых
В RxJS версии 5 следующий код приводит к завершению процесса после трех итераций обеих подписок: var Rx = require("rxjs"); const published$ = Rx.Observable.interval(1000).publish(); published$.subscribe(index => { console.log(`One:...
864 просмотров

RxJs: доступ к данным перед flatMapLatest после завершения flatMapLatest
Сценарий: Пользователь использует фильтры, объединенные в единый поток Когда фильтры меняются, событие для бэкэнда запускается для получения «дешевых» данных. Когда поступают «дешевые» данные, другой запрос с теми же параметрами отправляется...
224 просмотров
schedule 20.10.2022

Отсутствует плоская карта rxjs
Я пытаюсь связать несколько наблюдаемых rx.js и передать данные. Flatmap должен быть оператором подгонки, но с импортом import { Observable } from 'rxjs/Observable'; не найдено: Error TS2339: Property 'flatmap' does not exist on type...
45279 просмотров
schedule 19.04.2023

Объедините несколько наблюдаемых с разными действиями / операциями
Я создаю приложение Angular2, поэтому привыкаю к ​​Observables и Reactive Extensions в целом. Я использую TypeScript и rxjs. Теперь у меня есть наблюдаемая или, если хотите, поток массива некоторых объектов. Скажем, Человек-объекты. Теперь у...
1461 просмотров

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

Какая связь между Reactive-Extension и ReactiveX
В чем разница/отношение между этими двумя группами github: Reactive-Extensions ( https://github.com/Reactive-Extensions ) ReactiveX ( https://github.com/ReactiveX )
52 просмотров