Вопросы по теме 'rxjs6'

Ошибка expect () внутри subscribe () не означает, что тест недействителен
Недавно мы обновились до Angular 6.0.3, RxJs 6.2.0 и jest 23.1.0 (обновление с RxJS 5 и Angular 4). Кажется, есть проблема с Jest & RxJs, поскольку невыполненные операторы ожидания внутри блока подписки не помечают тест как неудачный. Вот...
1561 просмотров
schedule 25.09.2021

Rxjs6 от rxjs5: обработка наблюдаемых в методе REST API
Я новичок в rxjs и Angular, и я только что обнаружил (благодаря моему WebStorm, выдающему множество красных сообщений об ошибках), что rxjs5 сильно отличается от версии 6. Итак, я следую этому руководству , которое направляет пользователей через...
251 просмотров
schedule 24.11.2021

Как я могу иметь одновременно активными только X наблюдаемых?
Я использую RxJS v6, но ответ может относиться и к RxJS v5. Я хотел бы сделать так, чтобы если бы я сказал 8 значений, у меня было бы только 4 активно обрабатываемых за раз. Код, который у меня сейчас есть, отправляет 4 элемента, затем...
46 просмотров
schedule 25.11.2021

Как зациклить эпический звонок
У меня есть следующая эпопея: import { map, catchError, switchMap, takeUntil, } from 'rxjs/operators'; import { FETCH_JOKES, jokesReceived, FETCH_JOKES_CANCELLED, jokesFetchFailed, } from '../actions/jokes-action'; import { ofType...
485 просмотров

Магазин Ngrx получает ошибку, поскольку свойство 'ofType' не существует для типа
Я пытаюсь разработать приложение, используя ngrx/store сообщение об ошибке. не в состоянии понять проблему. кто-нибудь мне поможет? вот мои ошибки: ERROR in src/app/store/effects/authentication.effects.ts(25,7): error TS2339: Property...
9250 просмотров
schedule 08.10.2021

Трафарет с RxJS 6
У меня возникла проблема с использованием трафарета с rxjs 6 Просто создал компонент трафарета, выполнив npm init stencil и выбрав component из списка. Добавлен rxjs в package.json и обновлен трафарет до последней версии:...
371 просмотров
schedule 25.10.2021

Rxjs выдает ошибку тайм-аута из канала в секцию наблюдаемой ошибки
Я пытаюсь передать ошибку тайм-аута из наблюдаемого канала наблюдателю как ошибку, но я все еще получаю ошибку тайм-аута в обратном вызове val (в подписке), хотя я хочу получить его в обратном вызове ошибки: Для тех, кто экспериментирует, вы можете...
1088 просмотров

Ошибка при подписке. подписка - это не функция
var a$= from(['aaaa','bbbb']) var b$=from(ajax(`https://api.myjson.com/bins/no8tj`)) a$.pipe(mergeMap(post => b$).subscribe(res => console.log(res))); Я пытаюсь использовать оператор mergeMap. Но при...
101 просмотров
schedule 28.09.2021

После получения ответа на вызов post api выдается ошибка = ›.pipe не является функцией
Я делаю вызов api и ожидаю от него ответа, который может быть передан на второй вызов api, но я получаю сообщение об ошибке ОШИБКА TypeError: this.helperService.getPointIdbyTags (...) [0] .pipe не является функцией в строке .pipe...
92 просмотров
schedule 06.12.2021

Как использовать RxJS с определениями типов при использовании сборки UMD?
Например : npm я @ reactivex / rxjs Создайте файл index.ts с некоторой функцией, использующей RxJs Создайте файл index.html, который ссылается на сборку UMD RxJs, и файл index.js, созданный компилятором машинописного текста из файла index.ts....
335 просмотров
schedule 29.10.2021

Как работает подписка на http-запрос?
Как работает метод подписки, когда http-клиент запрашивает данные с конечной точки? Работает ли он как HTTP с одним запросом? Что делать, если источник в конечной точке имеет новые данные, а подписка показывает их после первого вызова?
182 просмотров
schedule 17.09.2021

Как запустить наблюдаемое в трубе в RxJS 6?
У меня есть этот код RxJS в моем проекте Angular: settingsService.getSetting('setting-name').pipe( map((setting: SettingInterface) => { // ... return setting; }), tap((setting: SettingInterface) =>...
160 просмотров
schedule 17.09.2021

rxjs: получить дубликаты HTTP-запросов в первом отправляемом мною наборе
Я сделал эту функцию, на каждой итерации у меня есть 7 запросов, которые отправляют каждое время environment.dashboard.frequency, но в начале я вижу, что я отправляю на сервер 14 запросов вместо 7: let requests: Observable<ResourceResponse>[]...
33 просмотров
schedule 29.10.2021

Выполнение вложенных вызовов API с использованием RxJS на основе условия с использованием оператора iif, что приводит к превышению максимального размера стека вызовов
Я пытаюсь использовать условный оператор rxjs. Я проверяю, хранятся ли данные в local storage , верните это, если нет, сделайте 2 HTTP-вызова, чтобы получить необходимые данные и вернуть их. Вот мой код: // making nested API calls...
87 просмотров
schedule 07.03.2022

Как протестировать угловой компонент с помощью наблюдаемого ввода
Я пытаюсь протестировать Angular Component , который в основном получает Observable и изменяет его template на основе значений, испускаемых этим Observable. Вот упрощенная версия: @Component({ selector: 'async-text', template: `...
2889 просмотров
schedule 14.03.2022

Могу ли я использовать ownUntilKeyChanged для удаления повторяющихся объектов?
Я новичок в rxjs в Angular 7, у меня есть api, который возвращает данные пользователя. Я хочу удалить объекты с одинаковыми именами, я почти не пробовал его с помощью отличногоUntilKeyChanged (), но вывод в консоли такой же, как и из api отклик. а...
857 просмотров
schedule 18.03.2022

Выпустить предыдущие значения в виде массива в Rxjs 6?
Мне нужен наблюдаемый объект, который испускает массив предыдущих значений до X значений. По сути, что-то вроде bufferCount () , за исключением того, что я хочу, чтобы он срабатывал немедленно и вести историю бега....
279 просмотров
schedule 23.03.2022

Rxjs выполняет последовательные вызовы с использованием concatMap
Я хотел бы сделать два последовательных вызова (если первый завершился, вызовите второй): Мой код похож на: myApiClient .firstApiCall() .pipe(take(1), concatMap (firstResult => {...
57 просмотров
schedule 22.03.2022

Почему кран влияет на поток воды?
По какой-то причине наличие оператора касания изменяет вывод потока (фактически обеспечивая мой ожидаемый результат). Когда я снимаю кран, последующий фильтр перестает работать. Я запустил приведенный ниже код в CodeSandbox с...
32 просмотров
schedule 01.04.2022

Операторы Angular Map и mergeMap rxjs6
Вопрос новичка: Я пытаюсь экспортировать свои данные из API отдыха в firebase. Я использую Angular6 с RxJS 6 . getByTag(tag:string) { return this.http.get(this.URL + '/get/listings/', { headers }) .pipe( map((res: Listings)...
517 просмотров
schedule 10.04.2022