Описание тега reactive-extensions-js

Вопросы с тегом
Реактивные расширения для JavaScript - это набор библиотек для создания асинхронных, отказоустойчивых и отзывчивых программ, управляемых событиями, с использованием наблюдаемых коллекций с компоновкой стилей ECMA Script5 Array#extras в JavaScript.
2 ответа

Доступ к переменным позже в цепочке

В приведенном ниже примере я беру пользователя и создаю каталог для этого пользователя. Я хочу просто войти, что пользователь был создан. Какой лучший способ получить доступ к user переменная позже в цепочке? let ensureUser$ = ghUser$ .map(u => R…
08 мар '16 в 18:51
2 ответа

RxJS Observable, который ждет на Observable

Итак, у меня есть наблюдаемая, которая делает HTTP-пост для получения токена доступа с сервера. У меня есть другой, который выполняет добраться до того же сервера, но требует токен доступа с первого раза, чтобы существовать. Поэтому я хотел бы иметь…
06 янв '16 в 07:40
1 ответ

Как я могу создать страстную наблюдаемость из горячей наблюдаемой?

AFAIK, наблюдаемый ленив. import * as rxjs from 'rxjs' const { filter, take, map } = rxjs.operators function awesomeOpators() { return take(1); } const numbers$ = new rxjs.Subject<number>(); const start$ = numbers$.pipe( awesomeOpators(), ); n…
02 фев '18 в 15:18
1 ответ

Почему методы Observable.While и Observable.Prune находятся в пространстве имен Microsoft.Phone.Reactive?

Я заметил, что методы Observable.While и Observable.Prune являются частью пространства имен Microsoft.Phone.Reactive. Просто любопытно, почему это дается, эти методы должны быть применимы ко всем ОС?
07 мар '12 в 08:37
1 ответ

У меня есть цепочка Rx.Subjects (A->B->C->A), но последний шаг не работает

Живой пример. Я совершенно новичок в Rx*. Я пытаюсь создать реактивную версию MVC, используя RxJS для моей диссертации. Это свободно основано на https://github.com/staltz/mvi-example Я, вероятно, должен был изучить RxJS больше, прежде чем начинать …
23 фев '15 в 16:17
2 ответа

Как сохранить накопленный результат сканирования с помощью rxjs

У меня есть две объединенные наблюдаемые со сканированием после объединения. Первый - простой диапазон, а другой - Предмет. Всякий раз, когда субъект выдает новое значение с onNext Я объединяю это значение в скане и возвращаю новый массив в качестве…
31 май '15 в 23:12
2 ответа

RxJs: новое значение только по истечении определенного периода времени

Я новичок в ReactiveExtensions, и я не получаю работу s.th. что я думаю, должен быть очень распространенным вариантом использования. Я хочу получить новое значение только по истечении определенного периода времени без нового следующего значения. В н…
06 сен '16 в 19:18
2 ответа

Будет ли Rx.Observable.groupBy очищать пустые потоки?

В приложении Node я пытаюсь обработать поток событий, используя RxJS. Поток событий представляет собой список изменений многих документов. Я использую groupBy для разделения потока на новые потоки по documentId. Но мне интересно, как только документ…
21 май '15 в 16:17
0 ответов

RxJS 5: получить базовое значение в функции Lift

Я уже прочитал и попытался реализовать создание оператора. Также видел осложнения с этим Несмотря на то, что это хорошо для перегрузки операторов, я хотел бы использовать функцию lift для сохранения деталей времени в обрабатываемом значении без испо…
19 июн '16 в 18:05
3 ответа

RxJS - продолжить отправку уведомлений после возникновения ошибки в onNext

Я новичок в Rx, и я был бы очень признателен за небольшую помощь с обработкой ошибок. У меня есть следующий код, который в основном является typeahead: var observable = Rx.Observable.fromEvent(searchField, 'keyup') .map(ev => ev.target.value) .fi…
05 янв '17 в 18:37
1 ответ

Преобразуйте наблюдаемую последовательность в наблюдаемую последовательность, производящую значения только из самой последней наблюдаемой последовательности

Пример 1: var obsNumber = /* observable that produce numbers */; var obsText1 = /* observable that produce text */; var obsText2 = /* observable that produce text */; var obsContext = /* IF obsNumber < 5 THEN obsText1 ELSE obsText2 */; obsContext…
28 июн '13 в 10:43
2 ответа

Реактивные Расширения: Как создать наблюдаемый заполнитель?

У меня есть метод, getObs(), который возвращает наблюдаемое, которое должно быть общим для всех абонентов. Однако эта наблюдаемая может не существовать, когда кто-то getObs()и его создание является асинхронной операцией, поэтому моя идея заключалась…
09 июл '13 в 09:43
1 ответ

Как получить имя события Observable, созданного с помощью.fromEvent

Я пытаюсь ограничить, какие события, поступающие от общей шины сообщений, должны передаваться на сервер. Разрешенные события включены outgoingEvents массив. Проблема в том, что для правильной отправки их на сервер мне нужно имя события. var Events =…
07 дек '14 в 11:09
1 ответ

RxJS Интервал без задержки

Следующий код испускает int после 5000ms а потом еще в каждом 5000ms потом: let evens = Observable.interval(5000) .map(i => { return i * 2; }); evens.subscribe((i) => { console.log(i); }); Можно ли это сделать, но сразу получить первый результ…
07 мар '17 в 11:49
1 ответ

Rxjs глотает ошибки

Имея простой Rxjs стрим, я столкнулся с такой ситуацией: Rx.Observable .fromArray([1,2,3,4,5,6]) // if commented from here .windowWithCount(2, 1) .selectMany(function(x) { return x.toArray(); }) // to here .. the error bubbles up .subscribe(function…
09 июн '15 в 15:32
1 ответ

RxJS: рекурсивный список наблюдаемых и один наблюдатель

У меня были некоторые проблемы с рекурсивной цепочкой наблюдаемых. Я работаю с RxJS, которая в настоящее время находится в версии 1.0.10621 и содержит основную функциональность Rx в сочетании с Rx для jQuery. Позвольте мне представить примерный сцен…
27 мар '12 в 22:57
2 ответа

Как использовать Reactive Extensions для кэширования, регулирования и ретрансляции нескольких событий?

Я пытаюсь изучить новую платформу Reactive Extensions для.Net, и это звучит как идеальное решение для моего приложения. Изучив примеры (и все еще довольно слабые с LINQ), я изо всех сил пытаюсь выяснить, как использовать инфраструктуру RX для решени…
11 янв '13 в 23:24
1 ответ

RxJS - оператор блокировки

В RxJava есть оператор Observable.toBlocking() для синхронного извлечения данных наблюдаемой. Я не могу найти похожий оператор для RxJS. Я хочу использовать этот оператор для улучшения моего кода с помощью Rx и без использования другой библиотеки фу…
17 дек '15 в 14:30
2 ответа

Отделение отдельных кликов от нажатия и удержания

Мне нужно реализовать поведение: когда элемент нажал - происходит одна вещь но когда он щелкается и удерживается более одной секунды, происходит что-то еще (например, элемент становится перетаскиваемым), а затем первое событие никогда не срабатывает…
24 фев '15 в 21:18
0 ответов

Периодическое событие rx javascript игнорировать до первой обработки

Возможно я пропустил назначение RX для библиотеки javascript, но я думаю, что он должен хорошо справиться с этим сценарием. Я хотел бы, чтобы периодические события генерировались через наблюдаемые. Подписчик должен принять первое событие и сделать з…
03 сен '12 в 10:36