Вопросы по теме 'rxjs-observables'

RXJS flatMap для повторяющегося наблюдаемого
Я пытаюсь реализовать службу, которая обеспечивает наблюдаемое, если приложение подключено к моему серверу или нет, поэтому, когда браузер в сети, мы проверяем сервер с таймером. Вот код: public get $connected(): Observable<boolean> {...
81 просмотров

RxJs: Можете ли вы распространять операторы в качестве аргументов в оператор конвейера
У меня есть два наблюдаемых потока, которые выполняют очень отдельную логику сопоставления, но в конечном итоге заканчиваются следующими тремя операторами: this.selection .pipe( ..Custom mapping operators tap(_ =>...
749 просмотров

Как завершить наблюдаемую карту переключателей rxjs?
У меня есть наблюдаемый в моем проекте angular 8 и я подписываюсь на ngOnInit (). export class ChartComponent implements OnInit { urlSubject: Subject<string> = new Subject(); isLoading: BehaviorSubject<boolean> = new...
1152 просмотров

Выполнить функцию после завершения подписчиков на наблюдаемый RxJS
В RxJS мне нужно выполнить некоторый код после того, как были выполнены все подписки для данного наблюдаемого объекта. Мне нужно делать это после каждого срабатывающего next уведомления и после завершения всех функций подписчика (а не только один...
1173 просмотров

GroupBy an RxJS Observable в пары "ключ-значение"
У меня есть следующие записи типа Observable ‹User []›: [{ "id": 1, "name": "Testuser 1", "projectAccess": Role, }] Role { id: string; name:string; } поэтому требование похоже на наличие...
60 просмотров

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

Angular - вложенные вызовы REST API возвращают только внутренний вызов
ShoppingCart с ShoppingCartItems извлекается через внешний вызов REST, после чего Observable из ShoppingCartItems выполняет внутренний вызов для улучшения ShoppingCartItems с помощью Provider. Касание (console.log) после внутреннего вызова...
248 просмотров

RxJS подписаться на изменение количества подписчиков
Проблема: я использую Subject observable для передачи строковых данных между компонентами (которые находятся слишком далеко друг от друга в иерархии). Я хотел бы иметь возможность сказать, сколько подписчиков на Subject, когда компонент...
41 просмотров

Angular 7 Transform Observable ответ на новый наблюдаемый объект
У меня есть API с такими ответами, и я использую наблюдаемые rxjs [{ "error": "error_1", "types": [ { "type": "new_type" }, { "type": "old_type" } ], "date": "2019-08-29" }] Мне нужно преобразовать...
1300 просмотров

Как дождаться асинхронного метода, определенного внутри подписки, до завершения наблюдаемого Rxjs?
Возьмем следующий код: myObservable.subscribe({ next: async () => { await something(); }, complete: () => { console.log('All async task are comlpeted'); } }); Проблема в том, что console.log вызывается после...
222 просмотров
schedule 16.03.2022

Подождать, пока значение наблюдаемого объекта (в виде списка) вызовет другое наблюдаемое, используя каждый член из списка?
Я использую 3 конечные точки для своего приложения, одна из конечных точек зависит от ответа другой конечной точки, который является списком, тогда мне нужно использовать каждый элемент списка, чтобы использовать другую конечную точку, давайте назовем...
54 просмотров
schedule 28.03.2022

Angular данные слияния наблюдаемых потоков RxJs
Я пытаюсь реорганизовать свой код Angular, чтобы он стал более "реактивным" У меня есть данные, возвращенные из Observable, который возвращает данные учетной записи $ в объект, например: { accountid: "123435", name: 'bob', customerId:...
154 просмотров
schedule 22.04.2022

Преобразование данных из одного наблюдаемого с использованием другого наблюдаемого в угловом rxjs
У меня есть две наблюдаемые: города и адреса. В моем массиве addresses у меня есть объект со свойством city_code , которое имеет значение, и свойство city , которое пусто. В cities у меня есть объекты с обоими свойствами. Как я могу...
78 просмотров
schedule 30.04.2022

как объединить несколько наблюдаемых при первом завершении наблюдаемого и вернуть в качестве нового наблюдаемого в методе
Я новичок в использовании операторов RxJs, и у меня есть потребность в методе, который вызывает 5 наблюдаемых из службы, и он должен извлекать данные из службы только после завершения первого наблюдаемого, затем объединить все наблюдаемые и...
460 просмотров
schedule 08.05.2022

Попробуйте преобразовать объект (приведение типов) с помощью оператора карты в angular
Ответ API (json) - { "count": 1050, "next": "....", "previous": null, "results": [ { "name": "Test1", "url":...
78 просмотров
schedule 04.07.2022

rxjs: загружать многие для многих из 2 конечных точек и объединять в один Observable
У меня есть одна конечная точка для получения списка пользователей и другая для получения списка квартир для каждого пользователя: getUsers() => Observable<User[]>; getUserApartments(userId) => Observable<Apartment[]>` Как...
39 просмотров

Как извлечь только определенные свойства json, возвращая их как наблюдаемые с помощью rxjs
Например, это json, который я получаю, { "events": [... ], "total": 12341, "students": [ { "id": 1, "first_name": "John",...
100 просмотров

В Jest, как я могу модульно протестировать метод, который подписывается на наблюдаемый
У меня есть различные методы в моих компонентах, которые подписываются на методы во внедренных зависимостях, которые возвращают наблюдаемые. Я хочу написать модульные тесты Jest, чтобы убедиться, что когда эти наблюдаемые возвращают/ошибка, мои...
7902 просмотров

Как обновить сумму из динамически созданных входов?
У меня есть несколько входов, которые создаются динамически (можно добавлять или удалять входы). и текстовое поле, которое показывает сумму входных данных. Как я могу динамически прикрепить наблюдаемые и как мой текст может подписаться на все из...
152 просмотров
schedule 06.05.2023

Подписка не запускает ошибку при ответе сервера с ошибкой 400 http
Я совершенно не понимаю, почему ошибка не срабатывает это код, в котором я вызываю сервер this.userService.createUser(values).subscribe((response)=> { this.alertService.showConfirm("Usuario creado");...
102 просмотров