Вопросы с меткой [rxjs]

Руководство по использованию метки отсутствует.

Фильтрация
Сортировка
Метки
0 голосов
0 ответов
97 показов

RxJs запросы в цикле

У меня есть список параметров и для каждого параметра отправляется запрос на сервер. Количество параметров может быть разным, поэтому запросы отправляются в цикле. Вопрос, как мне отправить запросы по ...
0 голосов
0 ответов
13 показов

angular и библиотека ngx indexed db

Пытаюсь с помощью курсора обойти все записи в таблице из indexeddb. Хочу вытаскивать данные из таблицы порциями, а не все сразу, но никак не получается. loadNotes() { this.dbService.openCursor(...
0 голосов
1 ответ
24 показа

Synchronized при вызове angular-сервиса

В Angular 15 приложении есть несколько компонентов, которые одновременно вызывают метод сервиса (который вызывает rest бакенда). Сам сервис сразу проверяет, есть ли уже требуемые данные во внутреннем ...
0 голосов
1 ответ
38 показов

Group data by key with the groupBy operator rxjs

"rxjs": "7.8.0", C сервера приходит Observable c таким значением: [ { "id": 1, "date": 1693229400000, "name": "event ...
5 голосов
2 ответа
324 показа

Как передать данные из одного компонента в другой при событии

У меня есть app.component.html: <div class="container"> <app-filter (filter)="applyFilter($event)"></app-filter> <app-table [elementData]="elementData&...
0 голосов
1 ответ
121 показ

Как в Angular + Rxjs выполнить операции внутри потока только тогда(ожидая), когда значение другого потока будет true? (не filter!)

Есть Observable, но пропускать данные нужно только тогда, когда значения другого Observable= true. Пример - выполняю http запросы, а если токен невалиден, я блокирую выполнение запросов на момент, ...
0 голосов
2 ответа
864 показа

Собрать данные в один объект из нескольких запросов RxJS

На OnInitе нужно иметь массив: let finalArray = [ {code:7865, price:203, color: red}, {code:8865, price:303, color: pink}, ...] Из запроса на url1 получаем массив объектов по количеству которых, ...
0 голосов
1 ответ
173 показа

Angular подписка внутри подписки

В компоненте есть вызов сервиса, после ответа которого надо проверив внутреннее состояние или вызвать другой метод или показать модальное окно и потом вызвать этот метод. Из за этого получается ...
0 голосов
0 ответов
118 показов

Ответ от сервера в течении определенного времени

Суть в чём: использую Nest.js. Мой GET запрос в сервисе отправляет POST запрос на создание заказа, но момент в том, что сервер, к которому идёт запрос обрабатывает его(запрос) порядка 8 секунд, и ...
0 голосов
1 ответ
294 показа

Как отписаться внутри подписки rxjs, когда будет выполнено условие

ts: import {interval, of, Subscription, Observable, takeUntil} from 'rxjs'; private statusSubscription: Subscription; ngOnInit() { this.infoSubscription = interval(1000) .pipe(switchMap(() =&...
0 голосов
1 ответ
134 показа

Как сделать Rxjs interval в запросе

Service: import {Injectable} from '@angular/core'; import {HttpClient, HttpHeaders} from '@angular/common/http'; import {Observable} from 'rxjs'; @Injectable({ providedIn: 'root' }) export class ...
0 голосов
0 ответов
121 показ

Как убрать подписку в подписке c помощью rxjs angular?

ngOnInit(): void { this.sub.add( this.orderService.getOrders().pipe( map((orders: CreatedOrders[]) => { return orders.map((order: CreatedOrders) => { ...
1 голос
0 ответов
177 показов

Как отписаться от post запроса Angular?

У меня есть простой post запрос, который я использую для создания сообщений. Проблема в том, что функция sendMessage() будет работать абсолютно одинаково всегда после ее первого вызова, отправляя одно ...
0 голосов
0 ответов
46 показов

RxJs группировка элементов массива в диапазоны дат

Я в процессе изучения RxJs и задался вопросом группировки. Есть коллекция данных о ежедневных продажах const purchases:any[] = [ {date:"02.04.2022", purchases:2}, {date:"03.04....
0 голосов
0 ответов
83 показа

RxJs очередь асинхронных действий. Как проще написать мой код?

Есть такое страшилище. Не могу найти как при помощи RxJs упростить запись последовательностей асинхронных действий. public buyMedia(mediaId:number, customerId:number):Observable<any>{ ...
0 голосов
1 ответ
295 показов

Как с помощью RxJS положить значение в переменную?

Есть функция: getData (id: number, objectId: number): Observable<ObjectData | undefined> { let res$; if (!this.objectData.length) { this.loadObjectData(id) .subscribe((objectData) =&...
1 голос
0 ответов
64 показа

Как в RxJs выполнить функцию если значение BehaviourSubject true, а если false - то ждать пока не станет true?

у меня есть необходимость создать подписку и выполнить значение внутри только если значение другого BehaviourSubject равно true, а если нет, то не пропускать, а ждать, когда станет true и выполнить ...
0 голосов
1 ответ
54 показа

Разъясните поведение iif

Я предполагал что iif (закоментированный) делает то же самое, что и переписанный if. Iif возвращается на switchMap. проблема в том, что когда доходит до iif, то выполнались оба блока (true блок и ...
0 голосов
1 ответ
254 показа

Как вызвать функцию после изменения ngModel?

Создал примерно такой инпут: <input type="text" [(ngModel)]="name"> Хотелось бы отследить изменение name через RxJS вместе с его замечательным Observer. В интернетах в ...
0 голосов
1 ответ
64 показа

Обработка и сохранение результатов иерархично связанных выпадающих списков в модальном окне при помощи RxJs

У меня есть компонент модального окна в котором находится два выпадающих списка (стоит учесть что в будущем их будет 5-6). Эти списки должны быть связанны между собой по иерархии, в том плане что если ...
0 голосов
1 ответ
323 показа

Как получить доступ к неименованным полям объекта

Из стора в Observable приходит объект типа { 1: 'test1', 2: 'test2', 3: 'test3', 4: 'test4' ... } Как я могу вывести в консоль значения test1, test2... не зная имена полей?
0 голосов
0 ответов
41 показ

Angular socket: 1 emit - 1 subcribe на него - 2 реакции

Доброе утро, буду очень благодарна если кто то сможет мне помочь. Ситуация следующая: у нас есть socket.on. Внутрь передается функция которая емитит данные. В моем случае они равны undefined. В ...
0 голосов
1 ответ
26 показов

В rxjs не получается отменить действие interval() ни с помощью takeWhile, ни с помощью unsubscribe()

Проблема в этом куске кода: useEffect(() => { console.log(status); let sub = interv.pipe( takeWhile(() => status === "run") ).subscribe((v) => { setS((...
1 голос
2 ответа
700 показов

Rxjs подписка только на последний запрос

Как правильней и лучше всего реализовать подписку только на последний запрос? Например: Отправляем запрос. Он обрабатывается долго. Отправляем повторно второй запрос и получаем сразу ответ. ...
0 голосов
1 ответ
909 показов

RxJS. Как вызвать цепочку Observable используя результат предыдущих вызовов?

Есть 2 метода на уровне сервиса, один из которых использует результат работы второго как параметр: export class ApiService { ... HttpClient и все прочее ... getType(request): Observable<...
0 голосов
2 ответа
345 показов

Angular RxJs последовательность потоков

Есть 4 сервиса. $service1, $service2, $service3, $service4. Необходимо проверить ответ первого, и если там выполняется условие то вызывать второй сервис и всегда надо вызывать 3 и 4 сервис. $service1....
0 голосов
1 ответ
94 показа

Данные с сервера приходят в полном объёме, можно увидеть в консоли (метод tap в effect.ts). Но html их не рисует? И как обработать error в компоненте?

actions.ts import { Action } from "@ngrx/store"; export enum ArticlesActions { LoadArticles = '[Articles Page] Load Articles', ArticlesLoadedSuccess = '[Articles Page] Articles ...
0 голосов
1 ответ
67 показов

Как полностью синхронизировать 2 реактивные формы (их значения), если они находятся в разных местах приложения? [Angular + RxJS]

Никак не могу решить такую задачку. Angular 11 + Angular material. Компоненты находятся далеко друг от друга. Есть компонент checkboxesForm содержащий в себе реактивную форму состоящую всего из 3х ...
0 голосов
1 ответ
140 показов

RXJS как сделать зависимые запросы?

Как сделать зависимые запросы? const streamClickRefresh = fromEvent(refresh, 'click') .pipe( switchMap( v => ajax.getJSON(gitUrl)) ); У меня имеется запрос помещенный в ...
0 голосов
1 ответ
389 показов

Angular 7, остановить поток вызовов по условию

Есть 3 сервиса которые необходимо вызывать последовательно: Observable1$, Observable2$, Observable3$ Я сделал вызов так: Observable1$.pipe( switchMap(createResponse => Observable2$(...
2 голоса
1 ответ
68 показов

Как получить значение из другого потока по клику?

Есть событие клика: const click$ = fromEvent(this.image.nativeElement, 'click'); И событие включения кнопки: const btnClick$ = fromEvent(this.button.nativeElement, 'click'); Как по клику click$ - ...
0 голосов
1 ответ
201 показ

Как правильно организовать серверный стриминг с grpc и nest.js?

Необходимо, чтобы клиент мог подписаться на некий "канал", из которого периодически будут сыпаться сообщения. В рамках текущего стека технологий пытаюсь организовать что-то такое: прото-файл:...
0 голосов
1 ответ
104 показа

Почему локальная переменная не инициализируется с блока subscribe?

getItems(): Observable<Item[]> { return this.http.get<Item[]>('./assets/data/data.json'); } У меня есть код, который возвращает Observable. Ниже другой компонент, в котором вызывается ...
0 голосов
0 ответов
47 показов

Как освободить ресурсы во время роботы rxjs interval

У я меня есть рабочий CountDown таймер, который ведет обратный отсчет до определенной даты. ngOnDestroy() { this.interv.unsubscribe(); } getDays(t) { return Math.floor( t / (1000 * 60 * ...
0 голосов
1 ответ
184 показа

RxJs: Цепочка Observable внутри scan оператора

Есть массив неких действий, пусть будет ['a1','a2','a3','a4']. b1, b2, b3, b4 - их результаты. Каждое действие - Observable. Подразумевается, что это действия над неким DTO, и каждое действие делает ...
-1 голос
1 ответ
56 показов

Открывание проекта с другой компоненты

Как по умолчанию при запуске проекта делать вывод не localhost:3000 а выбранную компоненту, к примеру localhost:3000/sign - чтоб такая компонента запускалось при открывании проекта
1 голос
1 ответ
52 показа

rxjs Subject не передает значения подписчикам

У меня есть приложение, которое обрабатывает запрос пользователя на покупку конкретных товаров и добавляет их в корзину. Для менеджмента этих действий я использую Subject и Subscription. Запрос на ...
0 голосов
0 ответов
101 показ

Rxjs, combineAll()

Помогите разобраться, пожалуйста, как работает следующий код: of("a", "b", "c") .pipe( map(x => interval(2000).pipe(take(2))), combineAll() ) .subscribe(...
0 голосов
0 ответов
86 показов

Subscribe в subscribe

У меня есть behaviorSubject, в котором хранится текущий юзер. Соответственно юзеру не получается вытащить заказы: // behaviorSubject this.auth.currUser.subscribe(x => console.log('...
0 голосов
1 ответ
727 показов

Как создать timeout Observable из события?

Моя задача - остановить таймер по двойному нажатию кнопки "wait". Это нужно сделать используя кастомный observable со своим timeout. Timeout нужен, так как задание гласит что между нажатиями ...
0 голосов
2 ответа
583 показа

Как проверить, пустой ли observable?

https://stackblitz.com/edit/angular-ivy-lcsphp Не понимаю, как сделать проверку на observable, если он пустой: <div *ngFor="let book of bookings$ | filterByStatus: 'pending' | async; trackBy: ...
0 голосов
1 ответ
79 показов

Сделать один pipe и применить для разных событий

Хочу сделать сделать один pipe и применять его для разных событий. Как это правильно сделать? import { fromEvent } from 'https://dev.jspm.io/rxjs@6/_esm2015'; import { map } from 'https://dev.jspm....
0 голосов
1 ответ
146 показов

Сортировка rxjs

Нужна помощь, сейчас у меня сделана сортировка только по алфавиту, но можно ли в списке городов на первое место поставить Москву, потом Санкт-Петербург и потом только по алфавиту Stackblitz
0 голосов
1 ответ
932 показа

Ожидание получения каждого ответа запроса

RxJS, Angular 9. Задача: в цикле нужно делать запрос для каждой item service.getData(item.param), дожидаться ответа и дальше итеарироваться по массиву. Пример: array.forEach(item => { if (!...
0 голосов
1 ответ
138 показов

Фильтрация полей формы с автокомплитом

Форма содержит поля с автокомплитом. При выборе элемента, он должен пропадать из выпадающего списка и добавляться обратно при удалении chips. Как можно отрефакторить listeningControls(), чтобы ...
0 голосов
0 ответов
697 показов

Как получить объект <T> из Observable<T>?

Проект Angular а-ля новостной портал. export class CategoriesService { constructor(private http: HttpClient) { } getCategories(): Observable<any> { return this.http.get('./assets/...
0 голосов
1 ответ
163 показа

По какой причине не срабатывает combineLatest?

Есть два observable, скомбинированных в массив. Однако, когда приходит момент обновиться, обновление не вызывается. Просто не срабатывает обновление. ngOnInit() { if (this.contentViews$) { ...
0 голосов
0 ответов
80 показов

Почему *ngIf всегда в else?

Подскажите в чем причина, такого поведения *ngIf - всегда срабатывает else и соответственно mat-spinner крутиться постоянно даже когда данные уже в observable. Проверял с http запросом и все работает ...
0 голосов
0 ответов
97 показов

Как узнать количество подписок в Subscription?

Я добавляю подписчиков в экземпляр Subscription. Как узнать сколько подписчиков находится в subscriptions? const subscriptions = new Subscription(); ... formKeys.forEach(key => { subscriptions.add(...
1 голос
1 ответ
221 показ

Проблемы с установкой RxJS

Создал index.html и script.js, подключил, установил RxJS с помощью npm install rxjs Но при попытке импортировать Observables import { Observable } from 'rxjs'; в консоли выскакивает такая ...