Вопросы с меткой [rxjs]
Руководство по использованию метки rxjs отсутствует.
112
вопросов
0
голосов
1
ответ
27
показов
Как в Angular + Rxjs выполнить операции внутри потока только тогда(ожидая), когда значение другого потока будет true? (не filter!)
Есть Observable, но пропускать данные нужно только тогда, когда значения другого Observable= true.
Пример - выполняю http запросы, а если токен невалиден, я блокирую выполнение запросов на момент, ...
0
голосов
0
ответов
29
показов
Помогите с заданием по rxjs
Здраствуйте. Прохожу видео уроки по Расширенным возможностям JS, тема о библиотеке RxJS и вот там задали вот такое задание:
Создайте приложение, в котором на странице будет 3 блока с рекламой. ...
0
голосов
1
ответ
80
показов
Angular подписка внутри подписки
В компоненте есть вызов сервиса, после ответа которого надо проверив внутреннее состояние или вызвать другой метод или показать модальное окно и потом вызвать этот метод. Из за этого получается ...
0
голосов
0
ответов
24
показа
Ответ от сервера в течении определенного времени
Суть в чём: использую Nest.js. Мой GET запрос в сервисе отправляет POST запрос на создание заказа, но момент в том, что сервер, к которому идёт запрос обрабатывает его(запрос) порядка 8 секунд, и ...
0
голосов
1
ответ
109
показов
Как отписаться внутри подписки rxjs, когда будет выполнено условие
ts:
import {interval, of, Subscription, Observable, takeUntil} from 'rxjs';
private statusSubscription: Subscription;
ngOnInit() {
this.infoSubscription = interval(1000)
.pipe(switchMap(() =&...
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 ...
0
голосов
0
ответов
68
показов
Как убрать подписку в подписке c помощью rxjs angular?
ngOnInit(): void {
this.sub.add(
this.orderService.getOrders().pipe(
map((orders: CreatedOrders[]) => {
return orders.map((order: CreatedOrders) => {
...
0
голосов
0
ответов
391
показ
SyntaxError: Cannot use import statement outside a module (2)
Я впервые пишу вопрос на этом ресурсе. Ранее этот вопрос уже рассматривался, но я не нашел для себя решения, даже в английской версии. aleksandr barakin порекомендовал мне создать новый вопрос.
Суть ...
0
голосов
0
ответов
39
показов
Как добиться зафиксированного скролла с помощью RxJs?
У меня есть блок с mat-table внутри. У него есть скрол. Изначально значение этого скрола 0. Мне нужно, чтобы значение было 2 или больше. Если прокрутить до высоты 0, чтобы автоматически ...
1
голос
0
ответов
84
показа
Как отписаться от post запроса Angular?
У меня есть простой post запрос, который я использую для создания сообщений. Проблема в том, что функция sendMessage() будет работать абсолютно одинаково всегда после ее первого вызова, отправляя одно ...
0
голосов
0
ответов
34
показа
RxJs группировка элементов массива в диапазоны дат
Я в процессе изучения RxJs и задался вопросом группировки.
Есть коллекция данных о ежедневных продажах
const purchases:any[] = [
{date:"02.04.2022", purchases:2},
{date:"03.04....
0
голосов
0
ответов
57
показов
RxJs очередь асинхронных действий. Как проще написать мой код?
Есть такое страшилище. Не могу найти как при помощи RxJs упростить запись последовательностей асинхронных действий.
public buyMedia(mediaId:number, customerId:number):Observable<any>{
...
0
голосов
1
ответ
171
показ
Как с помощью RxJS положить значение в переменную?
Есть функция:
getData (id: number, objectId: number): Observable<ObjectData | undefined> {
let res$;
if (!this.objectData.length) {
this.loadObjectData(id)
.subscribe((objectData) =&...
1
голос
0
ответов
45
показов
Как в RxJs выполнить функцию если значение BehaviourSubject true, а если false - то ждать пока не станет true?
у меня есть необходимость создать подписку и выполнить значение внутри только если значение другого BehaviourSubject равно true, а если нет, то не пропускать, а ждать, когда станет true и выполнить ...
0
голосов
1
ответ
28
показов
Разъясните поведение iif
Я предполагал что iif (закоментированный) делает то же самое, что и переписанный if. Iif возвращается на switchMap. проблема в том, что когда доходит до iif, то выполнались оба блока (true блок и ...
0
голосов
1
ответ
54
показа
Обработка и сохранение результатов иерархично связанных выпадающих списков в модальном окне при помощи RxJs
У меня есть компонент модального окна в котором находится два выпадающих списка (стоит учесть что в будущем их будет 5-6). Эти списки должны быть связанны между собой по иерархии, в том плане что если ...
0
голосов
1
ответ
164
показа
Как вызвать функцию после изменения ngModel?
Создал примерно такой инпут:
<input type="text" [(ngModel)]="name">
Хотелось бы отследить изменение name через RxJS вместе с его замечательным Observer. В интернетах в ...
0
голосов
1
ответ
159
показов
Как получить доступ к неименованным полям объекта
Из стора в Observable приходит объект типа
{
1: 'test1',
2: 'test2',
3: 'test3',
4: 'test4'
...
}
Как я могу вывести в консоль значения test1, test2... не зная имена полей?
0
голосов
0
ответов
36
показов
Angular socket: 1 emit - 1 subcribe на него - 2 реакции
Доброе утро, буду очень благодарна если кто то сможет мне помочь. Ситуация следующая: у нас есть socket.on. Внутрь передается функция которая емитит данные. В моем случае они равны undefined. В ...
0
голосов
1
ответ
24
показа
В rxjs не получается отменить действие interval() ни с помощью takeWhile, ни с помощью unsubscribe()
Проблема в этом куске кода:
useEffect(() => {
console.log(status);
let sub = interv.pipe(
takeWhile(() => status === "run")
).subscribe((v) => {
setS((...
1
голос
2
ответа
535
показов
Rxjs подписка только на последний запрос
Как правильней и лучше всего реализовать подписку только на последний запрос?
Например:
Отправляем запрос. Он обрабатывается долго.
Отправляем повторно второй запрос и получаем сразу ответ. ...
0
голосов
2
ответа
177
показов
Angular RxJs последовательность потоков
Есть 4 сервиса. $service1, $service2, $service3, $service4. Необходимо проверить ответ первого, и если там выполняется условие то вызывать второй сервис и всегда надо вызывать 3 и 4 сервис.
$service1....
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 ...
0
голосов
1
ответ
49
показов
Как полностью синхронизировать 2 реактивные формы (их значения), если они находятся в разных местах приложения? [Angular + RxJS]
Никак не могу решить такую задачку.
Angular 11 + Angular material.
Компоненты находятся далеко друг от друга.
Есть компонент checkboxesForm содержащий в себе реактивную форму состоящую всего из 3х ...
0
голосов
1
ответ
261
показ
Angular 7, остановить поток вызовов по условию
Есть 3 сервиса которые необходимо вызывать последовательно: Observable1$, Observable2$, Observable3$
Я сделал вызов так:
Observable1$.pipe(
switchMap(createResponse => Observable2$(...
0
голосов
1
ответ
85
показов
RXJS как сделать зависимые запросы?
Как сделать зависимые запросы?
const streamClickRefresh = fromEvent(refresh, 'click')
.pipe(
switchMap( v => ajax.getJSON(gitUrl))
);
У меня имеется запрос помещенный в ...
2
голоса
1
ответ
40
показов
Как получить значение из другого потока по клику?
Есть событие клика:
const click$ = fromEvent(this.image.nativeElement, 'click');
И событие включения кнопки:
const btnClick$ = fromEvent(this.button.nativeElement, 'click');
Как по клику click$ - ...
0
голосов
1
ответ
147
показов
Как правильно организовать серверный стриминг с grpc и nest.js?
Необходимо, чтобы клиент мог подписаться на некий "канал", из которого периодически будут сыпаться сообщения.
В рамках текущего стека технологий пытаюсь организовать что-то такое:
прото-файл:...
0
голосов
1
ответ
67
показов
Почему локальная переменная не инициализируется с блока subscribe?
getItems(): Observable<Item[]> {
return this.http.get<Item[]>('./assets/data/data.json');
}
У меня есть код, который возвращает Observable. Ниже другой компонент, в котором вызывается ...
0
голосов
0
ответов
42
показа
Как освободить ресурсы во время роботы rxjs interval
У я меня есть рабочий CountDown таймер, который ведет обратный отсчет до определенной даты.
ngOnDestroy() {
this.interv.unsubscribe();
}
getDays(t) {
return Math.floor( t / (1000 * 60 * ...
5
голосов
1
ответ
256
показов
Как передать данные из одного компонента в другой при событии
У меня есть app.component.html:
<div class="container">
<app-filter (filter)="applyFilter($event)"></app-filter>
<app-table [elementData]="elementData&...
0
голосов
1
ответ
127
показов
RxJs: Цепочка Observable внутри scan оператора
Есть массив неких действий, пусть будет ['a1','a2','a3','a4']. b1, b2, b3, b4 - их результаты. Каждое действие - Observable.
Подразумевается, что это действия над неким DTO, и каждое действие делает ...
-1
голос
1
ответ
50
показов
Открывание проекта с другой компоненты
Как по умолчанию при запуске проекта делать вывод не localhost:3000 а выбранную компоненту, к примеру localhost:3000/sign - чтоб такая компонента запускалось при открывании проекта
0
голосов
0
ответов
90
показов
Rxjs, combineAll()
Помогите разобраться, пожалуйста, как работает следующий код:
of("a", "b", "c")
.pipe(
map(x => interval(2000).pipe(take(2))),
combineAll()
)
.subscribe(...
1
голос
1
ответ
36
показов
rxjs Subject не передает значения подписчикам
У меня есть приложение, которое обрабатывает запрос пользователя на покупку конкретных товаров и добавляет их в корзину. Для менеджмента этих действий я использую Subject и Subscription. Запрос на ...
0
голосов
0
ответов
64
показа
Subscribe в subscribe
У меня есть behaviorSubject, в котором хранится текущий юзер. Соответственно юзеру не получается вытащить заказы:
// behaviorSubject
this.auth.currUser.subscribe(x => console.log('...
0
голосов
1
ответ
656
показов
Как создать timeout Observable из события?
Моя задача - остановить таймер по двойному нажатию кнопки "wait". Это нужно сделать используя кастомный observable со своим timeout. Timeout нужен, так как задание гласит что между нажатиями ...
0
голосов
2
ответа
470
показов
Как проверить, пустой ли observable?
https://stackblitz.com/edit/angular-ivy-lcsphp
Не понимаю, как сделать проверку на observable, если он пустой:
<div *ngFor="let book of bookings$ | filterByStatus: 'pending' | async; trackBy: ...
0
голосов
1
ответ
69
показов
Сделать один pipe и применить для разных событий
Хочу сделать сделать один pipe и применять его для разных событий.
Как это правильно сделать?
import { fromEvent } from 'https://dev.jspm.io/rxjs@6/_esm2015';
import { map } from 'https://dev.jspm....
0
голосов
1
ответ
116
показов
Сортировка rxjs
Нужна помощь, сейчас у меня сделана сортировка только по алфавиту, но можно ли в списке городов на первое место поставить Москву, потом Санкт-Петербург и потом только по алфавиту
Stackblitz
0
голосов
1
ответ
693
показа
Ожидание получения каждого ответа запроса
RxJS, Angular 9.
Задача: в цикле нужно делать запрос для каждой item service.getData(item.param), дожидаться ответа и дальше итеарироваться по массиву.
Пример:
array.forEach(item => {
if (!...
0
голосов
0
ответов
465
показов
Как получить объект <T> из Observable<T>?
Проект Angular а-ля новостной портал.
export class CategoriesService {
constructor(private http: HttpClient) {
}
getCategories(): Observable<any> {
return this.http.get('./assets/...
0
голосов
1
ответ
111
показов
По какой причине не срабатывает combineLatest?
Есть два observable, скомбинированных в массив. Однако, когда приходит момент обновиться, обновление не вызывается. Просто не срабатывает обновление.
ngOnInit() {
if (this.contentViews$) {
...
0
голосов
0
ответов
66
показов
Почему *ngIf всегда в else?
Подскажите в чем причина, такого поведения *ngIf - всегда срабатывает else и соответственно mat-spinner крутиться постоянно даже когда данные уже в observable. Проверял с http запросом и все работает ...
0
голосов
0
ответов
63
показа
Как узнать количество подписок в Subscription?
Я добавляю подписчиков в экземпляр Subscription. Как узнать сколько подписчиков находится в subscriptions?
const subscriptions = new Subscription();
...
formKeys.forEach(key => {
subscriptions.add(...
1
голос
1
ответ
195
показов
Проблемы с установкой RxJS
Создал index.html и script.js, подключил, установил RxJS с помощью
npm install rxjs
Но при попытке импортировать Observables
import { Observable } from 'rxjs';
в консоли выскакивает такая ...
1
голос
1
ответ
241
показ
Angular проверка email на наличия в базе
У меня есть форма:
this.auteficationForm = this.formBuilder.group({
email: new FormControl('', [ Validators.required, Validators.email, this.passwordValidator]),
name: new FormControl('', [ ...
3
голоса
1
ответ
62
показа
Временная смена потока в RxJS или отслеживание обрыва соединения с сервером в Websocket
Есть код, который обрабатывает данные приходящие с сервера через WebSockets и помещает их в state. Данные приходят непрерывно. Данные отображаются в виде шкалы. Нужно сделать так, что бы если ...
0
голосов
0
ответов
42
показа
Как сделать выборку по определенному признаку через pipe
Я делаю запрос на сервер для получения объекта. Объект, конечно же Observable<Object>. Как мне проверить статус объекта прямо через .pipe()?
Я имею ввиду, что мне каким-то образом нужно ...
0
голосов
2
ответа
1k
показов
Слияние двух Observable массивов
Есть поток №1 - initMessages$ В него приходят первые 10 сообщений для рендера.
Есть поток №2 = newMessages$ при срабатывании эвента, идет запрос в базу, на следующие 10 сообщений.
Как мне Обновить ...