reactive-extensions-js

0зной

1ответ

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

Я пытаюсь ограничить, какие события, исходящие из общей шины сообщений, должны быть отправлены на сервер. Допустимые события находятся на outgoingEvents массив. Проблема в том, что для правильной отпр

2зной

1ответ

$ createObservableFunction абонент получает overriden

Если я создаю наблюдаемый, используя метод $ createObservableFunction, и я подписываюсь на это наблюдаемое несколько раз. Последний абонент переопределяет любого другого абонента. Однако, если я созда

10зной

2ответ

Идиоматический способа оправиться от потока OnError

Отказа от ответственности: это продолжение за предыдущий Safe update for 2 dependent streams вопрос Что такого идиоматического способа обработки ошибок в RxJS (или любую другую реализации RX), что поз

7зной

1ответ

RxJS - Индикатор загрузки

Я изо всех сил пытаюсь разглядеть «Rx» способ отображения индикатора загрузки потока AJAX. $scope.$createObservableFunction("load") .take(1) .do(function(){ $scope.loading = true;

-1зной

1ответ

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

Live example. Я совершенно новым для Rx *. Я пытаюсь создать реактивную версию MVC, используя RxJS для моей диссертации. Это свободно основано на https://github.com/staltz/mvi-example Я, вероятно, дол

6зной

3ответ

RxJS: Продюсер-потребитель с прерыванием

У меня проблема с особыми потребностями производителя в RxJS: производитель медленно производит элементы. Потребитель запрашивает элементы и часто должен ждать производителя. Это может быть достигнуто

4зной

2ответ

Тестирование объекта с помощью TestScheduler в RxJs

Я использую RxJs для подсчета количества пакетов в определенное временное окно. Мой код в основном выглядит так: var packetSubject = new Rx.Subject(); var packetsInWindow = []; function startMonito