Вопросы по теме 'rxjs5'

Что может вызвать загрузку всех состояний магазина при изменении страницы?
Я использую ngrx / store , ngrx / effects и ngrx / router . Мои эффекты такие: @Effect() loadOneProduct$ = this.updates$ .whenAction(LOAD_ONE_PRODUCT) .switchMap(() => this.productService.loadOneProduct()) .map(oneProduct...
672 просмотров
schedule 16.09.2021

Преобразование кода RxJS v4 в v5, обработка очереди с вытягиванием
---abcde-----f-------gh-----i----> //Events У меня есть «рабочая очередь», за которой я хочу наблюдать / подписываться. Это массив командных объектов для обработки. Новые элементы работы обычно поступают пачками, и их необходимо...
179 просмотров

Сериализовать массив в элементы, преобразовать с помощью RxJS и собрать элементы обратно в массив
В Angular2 у меня есть много Observable<any[]> (Observable, который испускает массивы), которые являются потомками http.get() или передаются через операции веб-сокета и, следовательно, не используют .complete () , но с течением времени...
501 просмотров
schedule 21.09.2021

Привязка обратного вызова функции Angular 2 и RxJs к this заставляет HTTP-запрос повторяться снова и снова
У меня есть метод обработки наших ошибок из HTTP-запросов, и он выглядит так public handleError(err: any, caught: Observable<any>): Observable<any> { //irrelevant code removed this.logger.debug(err);//example of problem return...
1503 просмотров
schedule 15.10.2021

В чем разница между Reactive-Extensions / RxJS и ReactiveX / rxjs
Я немного смущен. В чем разница между этими библиотеками? https://github.com/ReactiveX/rxjs https://github.com/Reactive-Extensions/RxJS В чем разница между rx , @ reactivex / rxjs rxjs на npm. Если вы ищете npm, есть несколько...
2846 просмотров

couchdb; как получить документы непосредственно на первом уровне json, а не сгруппировать внутри значения - viewWithList
У меня есть проектный документ: «учетные записи» и представление: «учетные записи-просмотр». содержание представления: function (doc) { emit( doc._id, doc); } И мой код в экспрессе: db.view('accounts', 'accounts-view', function(err,...
257 просмотров
schedule 13.10.2021

Есть ли в RxJS противоположность оператору race?
У меня есть два наблюдаемых объекта, и я хочу послушать тот, который выдает свое первое значение последним, есть ли для этого оператор? Что-то подобное : let obs1 = Rx.Observable.timer(500,500); let obs2 = Rx.Observable.timer(1000,1000); // I...
1441 просмотров
schedule 11.10.2021

асинхронная труба с наблюдаемым в угловом 4
Я новичок в angular и начал склоняться к angular 4. Данные не связываются с директивой ngfor на компоненте, использующем асинхронный конвейер. Пожалуйста помоги Пользовательский сервис использует HTTP-запрос для получения данных из API:...
1760 просмотров
schedule 11.10.2021

Как я могу удалить и добавить элемент в массив по индексу в способе RxJS?
Итак, у меня есть массив «событий»: let events = Rx.Observable.from([1,2,3,4,5,6,7,8,9]); Могу добавить (нажать): let add = function(number){ events = events.concat([number]); } Я могу удалить: let remove = function(){ events...
3238 просмотров
schedule 26.09.2021

Невозможно получить все данные при объединении двух наблюдаемых в rxjs
Я создал две наблюдаемые из базы данных: const roomData$ = estab .query() .where('estab.type', 'like', 'rooms') .then((rooms) => { rooms.forEach((room) => { observer.next(room.data); }); });...
168 просмотров
schedule 27.10.2021

RxJS Obsevrable do () не вызывается
Почему функция do () не вызывается? export class AppComponent implements OnInit { name = 'Angular 5'; events = []; existingEvents = [1,2,3,4,6] ngOnInit() { let i = 0; this.events.push('Initial'); Observable.of(1,2,3,4,5)...
49 просмотров
schedule 14.09.2021

Как я могу иметь одновременно активными только X наблюдаемых?
Я использую RxJS v6, но ответ может относиться и к RxJS v5. Я хотел бы сделать так, чтобы если бы я сказал 8 значений, у меня было бы только 4 активно обрабатываемых за раз. Код, который у меня сейчас есть, отправляет 4 элемента, затем...
46 просмотров
schedule 25.11.2021

rxjs: получить дубликаты HTTP-запросов в первом отправляемом мною наборе
Я сделал эту функцию, на каждой итерации у меня есть 7 запросов, которые отправляют каждое время environment.dashboard.frequency, но в начале я вижу, что я отправляю на сервер 14 запросов вместо 7: let requests: Observable<ResourceResponse>[]...
33 просмотров
schedule 29.10.2021

Наблюдаемый экземпляр испускает без наблюдателя (или подписчика?)
Я использую наблюдаемое в Angular2. Насколько я знаю до сих пор, каждый экземпляр Observable поставляется с наблюдателем (1: 1), и когда мы генерируем что-то с помощью Observable.next (value), мы можем получить это значение с помощью...
2148 просмотров
schedule 05.03.2022

Наблюдаемый, наконец, при подписке
Согласно этому artcle , onComplete и onError функция subscribe являются взаимоисключающими. Это означает, что в моем subscribe будут запускаться события onError или onComplete . У меня есть логический блок, который должен выполняться...
113779 просмотров
schedule 08.03.2022

Возврат Observable ‹boolean› из метода обслуживания после разрешения двух подписок
Я пытаюсь настроить простой способ сравнения текущего имени пользователя с именем пользователя профиля в службе Angular. Очевидно, что имя пользователя профиля и имя пользователя должны разрешиться, прежде чем я смогу их сравнить, так как мне...
28399 просмотров
schedule 14.03.2022

Тип Observable ‹any› не может быть назначен типу JSON в angular2 с помощью rxjs5
Я хочу изменить весь свой EventEmitter на Subjects, поскольку это рекомендуемый способ обмена переменными и состояниями вместо генерации события. Но теперь у меня возникла проблема, и я просто не понимаю, как ее решить. Вот пример кода:...
951 просмотров
schedule 22.03.2022

объединение двух потоков наблюдаемых в RxJ в соответствии с определенными условиями
У меня есть два потока объектов, счета и балансы. Мне нужно объединить (присоединить) два потока в соответствии с id и account_id var accounts = Rx.Observable.from([ { id: 1, name: 'account 1' }, { id: 2, name: 'account 2' }, {...
3403 просмотров

Отписаться от RxJS Observables
У меня есть эти два объекта, и я хочу перестать слушать их события. Я совершенно не знаком с наблюдаемыми объектами и RxJS и просто пытаюсь работать с библиотекой Inquirer . Вот API RxJS для справки:...
13576 просмотров

Создание бесконечного списка прокрутки в машинописном тексте с помощью rxjs5
Я пытаюсь создать список с бесконечной прокруткой, используя TypeScript и rxjs. То есть я хочу, чтобы приложение получало несколько страниц результатов из бэкэнда, а затем получало больше результатов всякий раз, когда пользователь прокручивает вниз....
1881 просмотров
schedule 11.04.2022