Описание тега rxjs
Реактивные расширения для JavaScript (RxJS) - это набор библиотек для создания асинхронных программ и программ, основанных на событиях, с использованием наблюдаемых коллекций и композиции стилей Array Extras.
1
ответ
Возвращение наблюдаемой из наблюдаемой в угловом HttpInterceptor
Я использую @ngrx/store для получения токена из хранилища и помещения его в заголовки HTTP, я пытался использовать flatmap mergeMap, но все они продолжают дублировать запросы http, и когда я использую take(1), он отправляет запрос цикла и зависает, …
30 окт '17 в 20:21
2
ответа
Служба подписки запускается несколько раз внутри ngOnInit [Angular 2]
У меня проблема в том, что когда я иду на разные страницы и возвращаю банк на первую страницу, где находится этот компонент: ngOnInit() { this.getModal(); } getModal() { this.subscription = this.sharedService.itemEdit$.subscribe((bank: any) => { …
29 дек '16 в 10:53
2
ответа
RxJS concatMap подписка вызывается для второго Observable отдельно
Я пишу приложение Angular 6. Я ожидаю, что при изменении маршрута будет отображаться анимация загрузки, а также ожидающие запросы http. Так что у меня 2 Observables выглядят так. Для httpPendingRequests я реализую с помощью счетчика, написанного в H…
20 авг '18 в 01:40
1
ответ
AngularFire2 с Observables не перехватывает свойство $ref
Поэтому я начал использовать AngularFire2 (версия 4.0.0-rc.1) и застрял на этой проблеме: getWishlist$(): FirebaseListObservable<{}> { return <FirebaseListObservable<{}>>this.store.select(getFirebaseUID) .filter(res => res.isAut…
18 июн '17 в 20:25
3
ответа
Почему функция подписки не вызывается в angular 2?
Я использую наблюдаемые в угловых. На самом деле моя проблема, когда я нажимаю кнопку мой subscribe функция не называется почему? согласно документации subscribe функция будет вызывать, когда мы вызываем next функция https://plnkr.co/edit/83NaHoVaxi…
20 дек '16 в 07:14
1
ответ
Эквивалент rxjs concatAll() в rxjava
Моя цель - моделировать события с некоторой случайной (предопределенной) задержкой. Я моделирую события в RxJs, как показано ниже: var events = [ {id: 1, qty: 23, delayMs: 0}, {id: 1, qty: 231, delayMs: 3}, {id: 1, qty: 232, delayMs: 1}, {id: 1, qty…
28 дек '15 в 13:00
1
ответ
Как я могу преобразовать ошибку Http до ее обработки с помощью subscribe()?
У меня есть компонент angular2, который использует сервис, который использует Http сделать HTTP-запрос. Сервис выглядит примерно так: export class AuthenticateService { constructor(private http: Http) {} public authenticateUser(username: string, pas…
06 ноя '16 в 10:44
0
ответов
Как протестировать потоки RxJs4, содержащие цепочки обещаний
Мне трудно понять, как вынуть цепочку обещаний из моего потока Rx, чтобы я мог проверить это. Приведенный ниже фрагмент взят из документации RxJs createResolvedPromise и был дополнен цепочкой .then(()=>..) чтобы лучше имитировать мой код. При зап…
11 янв '17 в 11:06
2
ответа
Как связать оператор flatMap с наблюдаемым для N раз, когда N известен только во время выполнения?
Я сталкиваюсь с ситуацией, когда мне нужно сделать что-то вроде ниже. observableFoo .flatMap(bar(param[0])) .flatMap(bar(param[1])) //... .flatMap(bar(param[N])) function bar(param){ var fn = function(...){ // return some observable depending on par…
23 сен '14 в 06:44
2
ответа
Возврат наблюдаемой путем сопоставления другой наблюдаемой
Я пытаюсь отобразить наблюдаемую информацию, получить значение из возвращенной наблюдаемой, затем передать это значение в другую наблюдаемую и вернуть этот результат. Вот что у меня так далеко: getJobsByUser(user: User): Observable<Job[]> { re…
12 июн '18 в 05:03
3
ответа
Angular - RxJS - Как выполнить действия для отфильтрованных элементов в цепочке?
У меня есть труба, как это: this.parentFormControl.valueChanges .pipe( debounceTime(500), distinctUntilChanged(), tap(() => { this.focusIndex = -1; }), filter(() => this.myCondition()), switchMap((value: string) => { return this.http.get(va…
08 окт '18 в 15:53
1
ответ
RXJS для обработки двух разных событий, но первое, что происходит, должно отменить другое
rxjs довольно сложен для меня, и я застрял, пытаясь решить эту проблему. Наиболее близким решением, которое я нашел в стеке, является использование оператора слияния. Вот ссылка Я работаю в угловых 2. У меня есть поле ввода ввода в HTML <input (k…
24 авг '18 в 03:40
1
ответ
Действие по подписке () и отписаться ()
В RxJS я хотел бы предпринять какие-то особые действия, когда наблюдатель подписывается на Observable и когда он отписывается. Я могу конечно переписать subscribe() а также unsubscribe() методы, но это кажется грубым. Нет ли способа при создании наб…
28 ноя '16 в 15:33
2
ответа
Правильный способ наследования
Я читал исходный код RxJS4 и наткнулся на функцию, которая выполняет наследование ( https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/internal/util.js): var inherits = Rx.internals.inherits = function (child, parent) { function __() {…
15 янв '17 в 04:48
1
ответ
Из цепочки обещаний в Rx.js
У меня есть цепочка обещаний, подобная приведенной ниже, в которой есть три обещания. Сейчас я немного изучаю Rx.js и не могу понять, с чего начать, когда нужно преобразовать эти обещания в наблюдаемые и объединить эту информацию в различные функции…
10 фев '16 в 16:49
1
ответ
Angular2 - перехват исключений и отображение сообщений об ошибках
Я могу ловить исключения при использовании метода.subscribe() с catch(), но это делается на основе вызова службы. Есть ли способ поймать исключение, которое происходит в любом месте на странице, и отобразить его в представлении? Уловить исключения и…
14 фев '17 в 09:42
2
ответа
Подписки на RxJS Combine 2
У меня есть сервис, который выводит 2 наблюдаемые. 1 для получения текущего аутентифицированного пользователя, а другой для получения всех активных пользователей. На главном экране я хочу использовать обе эти наблюдаемые, это будет сделано (в настоя…
17 янв '18 в 17:07
2
ответа
Дождитесь окончания наблюдаемого цикла for, прежде чем продолжить цикл в Angular 5
Я перебираю массив объектов (называемых проектами). Цикл forEach содержит сервисный вызов, который возвращает наблюдаемое. Я пытаюсь дождаться обработки следующего проекта в массиве, пока не завершится наблюдаемое в цикле. Что я должен использовать?…
03 фев '18 в 03:21
1
ответ
Вызов метода OnNext () из Observable внутри его производной цепочки
У меня есть такой код: function getTokenFromStorage(cb) { // Get token from storage var token = getToken(); // Feed it to callback function cb(token); } var subject = new Rx.BehaviorSubject(42); var token = subject .flatMap(function() { return Rx.Ob…
17 дек '15 в 16:35
2
ответа
Как подписаться на изменения значения на входе из другого модуля в Angular 6?
У меня есть компонент заголовка, который находится в модуле root (app). Панель поиска будет отображаться в заголовке в зависимости от активированного маршрута. У меня есть загруженный модуль друзей с компонентом контейнера списка друзей, который пре…
09 июн '18 в 15:04