Вопросы по теме 'rxjs-pipeable-operators'
Правильная защита типов пользовательских конвейерных операторов RxJS
Я работаю с API, который имеет фиксированную согласованную структуру ответов: это всегда объект, на котором есть свойство data . Поскольку постоянно отображать данные в запросах RxJS (или эффектах ngrx) очень утомительно и слишком явно, я решил...
415 просмотров
schedule
29.10.2021
RXJS flatMap для повторяющегося наблюдаемого
Я пытаюсь реализовать службу, которая обеспечивает наблюдаемое, если приложение подключено к моему серверу или нет, поэтому, когда браузер в сети, мы проверяем сервер с таймером. Вот код:
public get $connected(): Observable<boolean> {...
81 просмотров
schedule
10.10.2021
RxJs: Можете ли вы распространять операторы в качестве аргументов в оператор конвейера
У меня есть два наблюдаемых потока, которые выполняют очень отдельную логику сопоставления, но в конечном итоге заканчиваются следующими тремя операторами:
this.selection
.pipe(
..Custom mapping operators
tap(_ =>...
749 просмотров
schedule
27.10.2021
Выполнить функцию после завершения подписчиков на наблюдаемый RxJS
В RxJS мне нужно выполнить некоторый код после того, как были выполнены все подписки для данного наблюдаемого объекта. Мне нужно делать это после каждого срабатывающего next уведомления и после завершения всех функций подписчика (а не только один...
1173 просмотров
schedule
12.11.2021
Angular - вложенные вызовы REST API возвращают только внутренний вызов
ShoppingCart с ShoppingCartItems извлекается через внешний вызов REST, после чего Observable из ShoppingCartItems выполняет внутренний вызов для улучшения ShoppingCartItems с помощью Provider.
Касание (console.log) после внутреннего вызова...
248 просмотров
schedule
09.09.2021
Как поделиться HttpClient GET с BehaviorSubject?
Итак, я использовал shareReplay (1) для кеширования массива элементов в памяти, которые возвращаются из вызова HttpClient GET.
if (!this.getItems$) {
this.getItems$ = this.httpClient
.get<Item[]>(url, options)...
107 просмотров
schedule
15.11.2021
angular 6 фильтрует результаты async pipe
Я использую angular 6, и я хотел бы отфильтровать результаты асинхронного конвейера, прежде чем отображать их в пользовательском интерфейсе.
Вот мой код прямо сейчас
this.results = this.form.get('name').valueChanges.pipe(...
7174 просмотров
schedule
16.04.2022
Rxjs, Труба с одним аргументом
Существуют ли какие-либо различия при использовании функции Pipe с одним аргументом по сравнению с использованием функции Pipe вообще?
В настоящее время я реализую стратегию отмены подписки takeUntil из эту статью . В «официальном решении» от...
737 просмотров
schedule
19.05.2022
Тестирование обратных вызовов RXjs 6 с помощью jasmine
Вот простая почтовая функция, я могу успешно выполнить модульное тестирование и поймать ошибку в jasmine. Можно ли протестировать финализацию в жасмин? то есть в финализации, можем ли мы ожидать, что загрузчик будет закрыт или нет?...
839 просмотров
schedule
09.07.2022
Оператор timeout () не работает в теме Rxjs канала
У меня проблема с оператором тайм-аута в теме.
моя проблема выглядит как образец выше, но у меня есть все исходники,
ответ: наблюдаемый: 1 наблюдаемый: 2
url: https://stackblitz.com/edit/ou5yp1?file=index.ts
import { Subject,...
630 просмотров
schedule
07.08.2022
Observable, передаваемый через `share()`, вызывает одного наблюдателя ненужное количество раз.
Я пытаюсь проверить задержку сообщений, отправленных через общий/горячий наблюдаемый объект. Я заметил, что когда у меня есть несколько наблюдателей на одном общем наблюдаемом объекте, один наблюдатель вызывается n раз из одного сообщения (где n...
28 просмотров
schedule
06.09.2022
rxjs: загружать многие для многих из 2 конечных точек и объединять в один Observable
У меня есть одна конечная точка для получения списка пользователей и другая для получения списка квартир для каждого пользователя:
getUsers() => Observable<User[]>;
getUserApartments(userId) => Observable<Apartment[]>`
Как...
39 просмотров
schedule
22.09.2022
Порядок выполнения операторов RxJS
Учитывая, что у меня есть следующий код:
private readonly postAction$ = new Subject();
postStream$ = this.postAction$.pipe(
exhaustMap(() => {
this.count ++;
console.log('fired')
return of('my other post');
}),...
728 просмотров
schedule
27.09.2022
Труба RxJS для фильтрации на 2+ ответвления
Предположим, у нас есть субъект, который может возвращать заданный набор значений, для каждого из которых может потребоваться другой подход к ним. Мы могли бы обсудить, должно ли это когда-либо быть, НО это не совсем предмет моего исследования....
766 просмотров
schedule
12.05.2023
Rxjs, как этот синтаксис действителен?
Здравствуйте, в документации Rxjs я вижу этот код:
first()(of(1, 2, 3)).subscribe((v) => console.log(`value: ${v}`));
// Logs:
// value: 1
Я знал, что это похоже на Just as [1, 2, 3].map(x => x * x) , но я хотел бы знать, можем ли мы...
90 просмотров
schedule
31.03.2023
Обновление наблюдаемого массива Rxjs путем добавления, фильтрации или удаления элементов
У меня есть несколько карточек, отображаемых в пользовательском интерфейсе.
<div *ngFor="let item of cards | async">...</div>
Obviosuly карты будут Observable массива типа card.
Итак, у меня есть интерфейс карты, скажем,...
337 просмотров
schedule
11.01.2023
Как сохранить последнее значение из наблюдаемого массива асинхронных каналов при ожидании обновления в Angular 11/Rxjs
Я перебираю массив объектов, полученный от службы с помощью «NgFor».
Сначала я обновил переменную массива объектов внутри метода подписки и понял две вещи.
this._myService.sendRequest(input).subscribe((value: SomethingInterface[]) => {...
46 просмотров
schedule
06.12.2022
RxJs Debounce не выдает никакого значения
Насколько я понимаю, debounce keeps track of the most recent value from the source Observable, and spawns a duration Observable by calling the durationSelector function
У меня есть следующий код
import { interval } from 'rxjs';...
57 просмотров
schedule
27.10.2023
