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

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

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

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

Есть Observable, но пропускать данные нужно только тогда, когда значения другого Observable= true. Пример - выполняю http запросы, а если токен невалиден, я блокирую выполнение запросов на момент, ...
Rakzin Roman's user avatar
  • 5,680
0 голосов
0 ответов
29 показов

Помогите с заданием по rxjs

Здраствуйте. Прохожу видео уроки по Расширенным возможностям JS, тема о библиотеке RxJS и вот там задали вот такое задание: Создайте приложение, в котором на странице будет 3 блока с рекламой. ...
user avatar
0 голосов
1 ответ
80 показов

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

В компоненте есть вызов сервиса, после ответа которого надо проверив внутреннее состояние или вызвать другой метод или показать модальное окно и потом вызвать этот метод. Из за этого получается ...
Lukas's user avatar
  • 1,567
0 голосов
0 ответов
24 показа

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

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

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

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

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

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

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

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

SyntaxError: Cannot use import statement outside a module (2)

Я впервые пишу вопрос на этом ресурсе. Ранее этот вопрос уже рассматривался, но я не нашел для себя решения, даже в английской версии. aleksandr barakin порекомендовал мне создать новый вопрос. Суть ...
stranger's user avatar
0 голосов
0 ответов
39 показов

Как добиться зафиксированного скролла с помощью RxJs?

У меня есть блок с mat-table внутри. У него есть скрол. Изначально значение этого скрола 0. Мне нужно, чтобы значение было 2 или больше. Если прокрутить до высоты 0, чтобы автоматически ...
Vladislav_Kazakov's user avatar
1 голос
0 ответов
84 показа

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

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

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

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

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

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

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

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

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

у меня есть необходимость создать подписку и выполнить значение внутри только если значение другого BehaviourSubject равно true, а если нет, то не пропускать, а ждать, когда станет true и выполнить ...
Rakzin Roman's user avatar
  • 5,680
0 голосов
1 ответ
28 показов

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

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

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

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

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

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

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

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

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

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

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

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

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

Как правильней и лучше всего реализовать подписку только на последний запрос? Например: Отправляем запрос. Он обрабатывается долго. Отправляем повторно второй запрос и получаем сразу ответ. ...
Степан Данилов's user avatar
0 голосов
2 ответа
177 показов

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

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

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

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

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

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

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

Есть 3 сервиса которые необходимо вызывать последовательно: Observable1$, Observable2$, Observable3$ Я сделал вызов так: Observable1$.pipe( switchMap(createResponse => Observable2$(...
Lukas's user avatar
  • 1,567
0 голосов
1 ответ
85 показов

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Как по умолчанию при запуске проекта делать вывод не localhost:3000 а выбранную компоненту, к примеру localhost:3000/sign - чтоб такая компонента запускалось при открывании проекта
Oleg Tsizdyn's user avatar
0 голосов
0 ответов
90 показов

Rxjs, combineAll()

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

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

У меня есть приложение, которое обрабатывает запрос пользователя на покупку конкретных товаров и добавляет их в корзину. Для менеджмента этих действий я использую Subject и Subscription. Запрос на ...
Not-a-Whale's user avatar
0 голосов
0 ответов
64 показа

Subscribe в subscribe

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

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

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

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

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

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

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

Сортировка rxjs

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

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

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

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

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

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

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

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

Подскажите в чем причина, такого поведения *ngIf - всегда срабатывает else и соответственно mat-spinner крутиться постоянно даже когда данные уже в observable. Проверял с http запросом и все работает ...
Сергей Логинов's user avatar
0 голосов
0 ответов
63 показа

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

Я добавляю подписчиков в экземпляр Subscription. Как узнать сколько подписчиков находится в subscriptions? const subscriptions = new Subscription(); ... formKeys.forEach(key => { subscriptions.add(...
Max's user avatar
  • 2,322
1 голос
1 ответ
195 показов

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

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

Angular проверка email на наличия в базе

У меня есть форма: this.auteficationForm = this.formBuilder.group({ email: new FormControl('', [ Validators.required, Validators.email, this.passwordValidator]), name: new FormControl('', [ ...
JuniorCoder's user avatar
3 голоса
1 ответ
62 показа

Временная смена потока в RxJS или отслеживание обрыва соединения с сервером в Websocket

Есть код, который обрабатывает данные приходящие с сервера через WebSockets и помещает их в state. Данные приходят непрерывно. Данные отображаются в виде шкалы. Нужно сделать так, что бы если ...
Jodest's user avatar
  • 43
0 голосов
0 ответов
42 показа

Как сделать выборку по определенному признаку через pipe

Я делаю запрос на сервер для получения объекта. Объект, конечно же Observable<Object>. Как мне проверить статус объекта прямо через .pipe()? Я имею ввиду, что мне каким-то образом нужно ...
urglmorl's user avatar
  • 109
0 голосов
2 ответа
1k показов

Слияние двух Observable массивов

Есть поток №1 - initMessages$ В него приходят первые 10 сообщений для рендера. Есть поток №2 = newMessages$ при срабатывании эвента, идет запрос в базу, на следующие 10 сообщений. Как мне Обновить ...
Nikolay Barda's user avatar