Вопросы с меткой [rxjs]
Руководство по использованию метки rxjs отсутствует.
85
вопросов
0
голосов
0ответов
23 показа
Как освободить ресурсы во время роботы rxjs interval
У я меня есть рабочий CountDown таймер, который ведет обратный отсчет до определенной даты.
ngOnDestroy() {
this.interv.unsubscribe();
}
getDays(t) {
return Math.floor( t / (1000 * 60 * ...
5
голосов
1ответ
98 показов
Как передать данные из одного компонента в другой при событии
У меня есть app.component.html:
<div class="container">
<app-filter (filter)="applyFilter($event)"></app-filter>
<app-table [elementData]="elementData&...
0
голосов
1ответ
23 показа
RxJs: Цепочка Observable внутри scan оператора
Есть массив неких действий, пусть будет ['a1','a2','a3','a4']. b1, b2, b3, b4 - их результаты. Каждое действие - Observable.
Подразумевается, что это действия над неким DTO, и каждое действие делает ...
-1
голос
1ответ
26 показов
Открывание проекта с другой компоненты
Как по умолчанию при запуске проекта делать вывод не localhost:3000 а выбранную компоненту, к примеру localhost:3000/sign - чтоб такая компонента запускалось при открывании проекта
0
голосов
0ответов
57 показов
Rxjs, combineAll()
Помогите разобраться, пожалуйста, как работает следующий код:
of("a", "b", "c")
.pipe(
map(x => interval(2000).pipe(take(2))),
combineAll()
)
.subscribe(...
1
голос
1ответ
19 показов
rxjs Subject не передает значения подписчикам
У меня есть приложение, которое обрабатывает запрос пользователя на покупку конкретных товаров и добавляет их в корзину. Для менеджмента этих действий я использую Subject и Subscription. Запрос на ...
0
голосов
0ответов
30 показов
Subscribe в subscribe
У меня есть behaviorSubject, в котором хранится текущий юзер. Соответственно юзеру не получается вытащить заказы:
// behaviorSubject
this.auth.currUser.subscribe(x => console.log('...
0
голосов
1ответ
149 показов
Как создать timeout Observable из события?
Моя задача - остановить таймер по двойному нажатию кнопки "wait". Это нужно сделать используя кастомный observable со своим timeout. Timeout нужен, так как задание гласит что между нажатиями ...
0
голосов
2ответа
108 показов
Как проверить, пустой ли observable?
https://stackblitz.com/edit/angular-ivy-lcsphp
Не понимаю, как сделать проверку на observable, если он пустой:
<div *ngFor="let book of bookings$ | filterByStatus: 'pending' | async; trackBy: ...
0
голосов
1ответ
34 показа
Сделать один pipe и применить для разных событий
Хочу сделать сделать один pipe и применять его для разных событий.
Как это правильно сделать?
import { fromEvent } from 'https://dev.jspm.io/rxjs@6/_esm2015';
import { map } from 'https://dev.jspm....
0
голосов
1ответ
50 показов
Сортировка rxjs
Нужна помощь, сейчас у меня сделана сортировка только по алфавиту, но можно ли в списке городов на первое место поставить Москву, потом Санкт-Петербург и потом только по алфавиту
Stackblitz
0
голосов
0ответов
28 показов
Почему многие используют в angular observables в сервисах?
Я в сервисе создаю переменную и функции и манипулирую переменными там.
Просмотрел код других программистов - у них у всех реализованы observables, subject и изменение не просто переменной, а .next(...
0
голосов
1ответ
60 показов
Ожидание получения каждого ответа запроса
RxJS, Angular 9.
Задача: в цикле нужно делать запрос для каждой item service.getData(item.param), дожидаться ответа и дальше итеарироваться по массиву.
Пример:
array.forEach(item => {
if (!...
0
голосов
0ответов
14 показов
Angular PUT request в ходе программы перестает работать
Всем привет
Возник вопрос связанный с работой http.put() request в Angular. В ходе программы, я обновляю данные о матче между двумя командами, и сами команды. Если я это делаю неспешна, то все данные ...
0
голосов
0ответов
29 показов
Как получить объект <T> из Observable<T>?
Проект Angular а-ля новостной портал.
export class CategoriesService {
constructor(private http: HttpClient) {
}
getCategories(): Observable<any> {
return this.http.get('./assets/...
0
голосов
1ответ
35 показов
По какой причине не срабатывает combineLatest?
Есть два observable, скомбинированных в массив. Однако, когда приходит момент обновиться, обновление не вызывается. Просто не срабатывает обновление.
ngOnInit() {
if (this.contentViews$) {
...
0
голосов
0ответов
51 показ
Почему *ngIf всегда в else?
Подскажите в чем причина, такого поведения *ngIf - всегда срабатывает else и соответственно mat-spinner крутиться постоянно даже когда данные уже в observable. Проверял с http запросом и все работает ...
0
голосов
0ответов
26 показов
Как узнать количество подписок в Subscription?
Я добавляю подписчиков в экземпляр Subscription. Как узнать сколько подписчиков находится в subscriptions?
const subscriptions = new Subscription();
...
formKeys.forEach(key => {
subscriptions.add(...
1
голос
1ответ
41 показ
Проблемы с установкой RxJS
Создал index.html и script.js, подключил, установил RxJS с помощью
npm install rxjs
Но при попытке импортировать Observables
import { Observable } from 'rxjs';
в консоли выскакивает такая ...
1
голос
1ответ
66 показов
Angular проверка email на наличия в базе
У меня есть форма:
this.auteficationForm = this.formBuilder.group({
email: new FormControl('', [ Validators.required, Validators.email, this.passwordValidator]),
name: new FormControl('', [ ...
3
голоса
1ответ
49 показов
Временная смена потока в RxJS или отслеживание обрыва соединения с сервером в Websocket
Есть код, который обрабатывает данные приходящие с сервера через WebSockets и помещает их в state. Данные приходят непрерывно. Данные отображаются в виде шкалы. Нужно сделать так, что бы если ...
0
голосов
0ответов
32 показа
Как сделать выборку по определенному признаку через pipe
Я делаю запрос на сервер для получения объекта. Объект, конечно же Observable<Object>. Как мне проверить статус объекта прямо через .pipe()?
Я имею ввиду, что мне каким-то образом нужно ...
0
голосов
2ответа
245 показов
Слияние двух Observable массивов
Есть поток №1 - initMessages$ В него приходят первые 10 сообщений для рендера.
Есть поток №2 = newMessages$ при срабатывании эвента, идет запрос в базу, на следующие 10 сообщений.
Как мне Обновить ...
0
голосов
1ответ
39 показов
Получение значения в сервисе (RxJS)
создаю независимый сервис, который будет выдавать наружу параметры поиска через Observable. как в данном случае выдавать наружу значения параметра поиска через Observable из сервиса
https://...
1
голос
3ответа
83 показа
Отписка внутри подписки rx js
подскажите последсвия использования отписки от потока, внутри подписки на поток.
В проектах моей компании вижу такую структуру:
let sub = method().subscribe(() => {
sub.unsubscribe();
...
})
...
0
голосов
2ответа
278 показов
Angular настройка AsyncPipe для постоянного получения данных с сервера (каждые несколько секунд)
Я недавно работаю с Angular и еще не уверенно себя чувствую с библотекой RxJs, по этому - прошу вашей помощи. Перепробовал кучу вариантов, но ничего не получается. Лучшее, что получилось - приведу ...
0
голосов
0ответов
22 показа
Как правильно заархитектурить экшен NGRX с двумя логическими шагами?
Есть такая структура стора
{
currentItem: 89,
items: [77, 89, 99]
}
и нужно написать такой экшен:
NavigateToFirst, Результатом которго будет такое состояние стора:
{
currentItem: 77,
...
0
голосов
1ответ
71 показ
Фильтрация полей формы с автокомплитом
Форма содержит поля с автокомплитом. При выборе элемента, он должен пропадать из выпадающего списка и добавляться обратно при удалении chips. Как можно отрефакторить listeningControls(), чтобы ...
0
голосов
0ответов
24 показа
Не могу передать данные от дочерних элементов
У меня есть следующая структура:
<angularComp1>
<angularComp2>
<a>Route to detail page</a>
<angularComp3>
<button>Edit </button>
...
0
голосов
0ответов
78 показов
Использование оператора RxJS ForkJoin
Как правильно переписать данную конструкцию с оператором RxJS ForkJoin?
this.arrItems.forEach((item) => {
this.objectService.update(item).subscribe();
});
с ForkJoin:
const ...
0
голосов
0ответов
43 показа
Как получить значения в не subscribe
export class PostComponent implements OnInit {
confirmPost:CreatePost[] = [];
unconfirmPost:CreatePost[] = [];
constructor(
private postService: PostService
) { }
ngOnInit() {
this.postService....
0
голосов
1ответ
85 показов
Как передать параметр по цепочке вниз в rxjs?
Как передать параметр из map ко второму switchMap?
@Effect()
navigateToTeams(): Observable<Action> {
return this.actions$
.pipe(
ofTypeDeepOne<AddTeam>(
...
2
голоса
1ответ
117 показов
Subject as Observable
Для чего к Subject применяют метод asObservable? Subject ведь самодостаточный, может быть и observer-ом и observable. Два примера ниже работают одинаково.
// пример1
let currentUserSubject$ = new ...
0
голосов
1ответ
284 показа
RxJS Таймер циклических запросов учитывающий время ответа
Ищу метод в RxJS (v6.x) что бы отправлять циклические запросы на сервер, предположим каждые 30 скунд на подобии { timer } from 'rxjs', но проблема в том что-бы не учитывать время самого запроса. На ...
0
голосов
0ответов
25 показов
Нужно вывести сообщение после завершения нескольких обращений к api
Добрый день в распоряжение Angular 4 есть метод который обращается к api и апдейтить сущности, это может быть 5 -10 и больше сущностей, то есть 5 -10 обращений к api. Мне нужно вывести сообщение ...
0
голосов
1ответ
65 показов
Angular + rxjs. Анимация добавления child элемента
Доброго времени суток.
Имею компонент:
class NotificatorComponent {
public notifications$: Subject<Array<Notification>> =
new Subject();
// ...
public ...
0
голосов
0ответов
60 показов
Есть ли альтернатива для вложенного subscribe? [дубликат]
Есть ли альтернатива для вложенного subsribe?
Хотелось бы сделать код более компактным.
this.modalService
.modalWindow(`Точно удалить товар "${name}" ?`, '')
.subscribe(
...
0
голосов
0ответов
38 показов
Infinite loop при обновлении store ngrx
В компонент приходят данные из стора (ngrx)
data$: Observable<Data | undefined>
В шаблоне мы их читаем, выводим
data$ | async
По клику в шаблоне вызываем метод updateData, который ...
0
голосов
0ответов
40 показов
RxJs combine http request
Всем привет, подскажите есть ли возможность в RxJs скомбинировать два http запроса таким образом чтобы параметры второго запроса возвращались в первом
a = http.get<any>(...);
b = http.get<...
0
голосов
0ответов
41 показ
Поиск репозиториев GitHub на RxJS
Программа должна искать репозитории на GitHub по термину, введенному в текстовое поле, и выводит найденные репозитории списком. Получаю ошибку в определении sequence2$:
Error: Type Observable is ...
0
голосов
1ответ
62 показа
Не обновляються данные в Mat-table Angular 6
У меня есть таблица, где я обновляю данные:
startEdit(row, i) {
const dialogRef = this.dialog.open(EditCategoryComponent, {
data: {id: row.id, name: row.name}
});
dialogRef.afterClosed()....
1
голос
1ответ
66 показов
Дождаться пока предыдущая подписка закончится
Есть подписка:
this.documentChange.asObservable().subscribe(value => {
if (this.autosave) {
value._id = this.documentId;
this.updateDocument(value, change);
}
});
Работает она так: ...
0
голосов
1ответ
379 показов
RxJS. Как вызвать цепочку Observable используя результат предыдущих вызовов?
Есть 2 метода на уровне сервиса, один из которых использует результат работы второго как параметр:
export class ApiService {
... HttpClient и все прочее ...
getType(request): Observable<...
0
голосов
0ответов
41 показ
Записать в NodeJS набор файлов асинхронно
В приложении NodeJS есть необходимость асинхронной записи множества файлов.
Пытаюсь делать так:
for (var l = 0; l < self.contentHyperLinks.length; l++) {
var _nameChapter = config.out_folder ...
0
голосов
1ответ
66 показов
Отлов изменений свойств сервиса в компонентах Angular
Всем привет, прошу помочь мне разобраться в чем проблема. Изучаю ангуляр и споткнулся на обсерверах.
Ситуация:
Есть сервис, который отправляет запрос getWeather() и полученный ответ назначает ...
2
голоса
1ответ
125 показов
Подписки на события используя RxJs
Я создаю Observable и подписываюсь на него дважды, но при этом обновление приходит только для последнего подписавшегося:
import { Observable } from "rxjs";
let observer;
let source = Observable....
0
голосов
1ответ
134 показа
Рекурсивный http запрос Angular + RxJS
При запросе на urlFirst получаем данные. Если данные содержат ключ со значением 'nextPage', нужно сделать запрос на urlNextPage, чтобы получить дополнительные данные и так далее, до тех пор пока в ...
0
голосов
1ответ
84 показа
Собрать данные в один объект из нескольких запросов RxJS
На OnInitе нужно иметь массив:
let finalArray = [
{code:7865, price:203, color: red},
{code:8865, price:303, color: pink},
...]
Из запроса на url1 получаем массив объектов по количеству которых, ...
0
голосов
1ответ
59 показов
Switch Map под капотом
Как технически срабатывает Switch Map?
Что конкретно происходит для того, чтобы отменить уже посланный с сервера на клиент запрос?
0
голосов
1ответ
73 показа
switchMap для единственного роута
При клике на кнопку срабатывает метод getDatafromServer.
Подскажите, правильно ли в Angular реализован switchMap для одного роута т.е. при повторном нажатии отменяется предыдущий запрос (если еще не ...