Публикации по теме 'rxjs-observables'
Типы тем в RxJS
Если вы читаете это, вы, вероятно, играли с различными типами тем, которые предлагает RxJS. Но знаете ли вы, почему вы конкретно используете каждый из них? Или, что более важно, вы используете тот, который вам действительно нужен?
Давайте подробнее рассмотрим четыре различных типа, доступных в RxJS:
Subject
BehaviorSubject
ReplaySubject
AsyncSubject
Предмет
Subject — это особый тип Observable, который позволяет передавать значения множеству наблюдателей...
Вопросы по теме 'rxjs-observables'
Получить подписчиков Observable и заставить их подписаться на другой Observable
Проще говоря
Учитывая существующий Observable (который еще не завершен), есть ли способ получить связанных подписчиков (функции, переданные для подписки), чтобы вместо этого заставить их подписаться на другой Observable?
Контекст
Служба в...
723 просмотров
schedule
23.05.2023
В ожидании двух методов, возвращающих наблюдаемые в angular
У меня есть два метода, которые вызывают вызовы API и возвращают наблюдаемые.
private method1(): Observable<Home> {
return homeService.call.get();
}
private method2(): Observable<User> {
return userService.call.get();
}
Тогда...
59 просмотров
schedule
08.02.2023
отправка get с прикрепленным наблюдаемым с угловым и ионным каркасом
Я потратил часы, пытаясь разными способами заставить этот Observable работать в ионном / угловом режиме. Я пробовал разные настройки и интерфейсы для плагина к Observable, который имеет свойства, которые являются строками. Я пробовал подключить JSON...
39 просмотров
schedule
22.07.2022
Как мне получить свои наблюдаемые значения для использования в эффекте NGRX
Честно говоря, я полный нуб в NGRX и имею ограниченный опыт работы с rxjs. Но по сути у меня есть код, похожий на этот:
@Effect()
applyFilters = this.actions$.pipe(
ofType<ApplyFilters>(MarketplaceActions.ApplyFilters),...
63 просмотров
schedule
03.12.2023
Использование http-клиента для получения значения с сервера и его использования для следующих шагов
У меня есть функция, как показано ниже, где мне нужно позвонить на сервер и получить значение, которое возвращает функция. Я использую подписку rxjs. Я получаю значение, но поскольку rxjs является асинхронным, функция возвращается до того, как...
47 просмотров
schedule
24.02.2023
Когда вы подписываетесь на rxjs, как вы сигнализируете своему тесту, если он терпит неудачу?
Я полный новичок. Проблема, с которой я столкнулся, заключается в том, что как только я выдаю ошибку в наблюдаемом rxjs, мой тест не знает об этом. Когда я подписываюсь на тест, и он терпит неудачу в rxjs, он просто выдает ошибку, и мне нужно...
64 просмотров
schedule
07.11.2022
Установка выбранного элемента выбранного элемента с помощью асинхронных каналов в Angular
Специалисты по угловым! Я пытаюсь понять асинхронные каналы в Angular, но я застрял в базовом сценарии. У меня есть два элемента select в пользовательском интерфейсе, один из которых содержит сообщения, а другой - связанные с ними комментарии. Я...
998 просмотров
schedule
22.08.2022
Хук отписки RxJS
Имея фрагмент кода, который извлекает некоторые данные в кеш и синхронизирует их с помощью соединения через веб-сокет, а также предоставляет интерфейс доступа к данным с помощью Observable, как я могу знать, что в какой-то момент нет подписчиков на...
328 просмотров
schedule
01.01.2023
Как установить текущий индекс или двигаться назад, хотя наблюдаемый rxjs?
Я использую наблюдаемую rxjs для моделирования последовательности шагов, которые происходят в моем приложении.
Псевдокод
const steps = [{id: "step1"}, {id: "step2"}, {id: "step3"}]
//... then at some point later do things based on the steps...
124 просмотров
schedule
16.08.2022
Angular observable никогда не завершается обработчиком
Ниже приведены фрагменты моего кода. Интересно, почему он НИКОГДА не сталкивается с обработчиком завершения? Что я хотел сделать, так это сначала вызвать службу A, чтобы получить объект A с заданным параметром маршрута ['key'], а затем вызвать...
94 просмотров
schedule
15.01.2023
RXJS Angular - обработка ошибок с использованием .subscribe и Observable
У меня есть backend api для создания нового продукта. Интерфейсный код angular должен вызывать серверный API. Как выполнить обработку ошибок с помощью ** .subscribe **. Я использую HTTPClient и Observable и читал о том, как RXJS использует...
748 просмотров
schedule
19.05.2023
Использование Angular Async Pipe для подписки на Observable
Я успешно подписываюсь на наблюдаемое в нескольких различных компонентах моего приложения Angular / Ionic. Однако, поскольку я делаю это вручную, это также означает, что мне нужно вручную отказаться от подписки на них, что я в настоящее время делаю в...
619 просмотров
schedule
01.07.2022
Наблюдаемые цепочки RxJ в Angular
Я использую RxJs 6.6.0 и Angular 9.
У меня есть две функции, которые возвращают Observable ‹'Class1'› и Observable ‹'number'›.
поэтому я использую для:
funcA().subscribe(x=>{ // do something...});
funcB().subscribe(x=>{// do...
373 просмотров
schedule
29.05.2023
Внутренняя наблюдаемая не обновляется
Я использую rxjs для получения владельцев регистраций и связанного с ними сервиса и образа сервиса, однако, когда сервис обновляется, он не отражается в моем наблюдаемом?
Может кто-нибудь понять, почему, что я делаю неправильно?
Я должен...
30 просмотров
schedule
01.11.2023
Как мне перебирать функции, которые возвращают наблюдаемые rxjs
Я хочу перебрать серию асинхронных функций и завершить итерацию, когда возвращается false. Я новичок в rxjs и не могу заставить работать описанный ниже вариант использования. Я чувствую, что не понимаю чего-то фундаментального. Может ли...
29 просмотров
schedule
29.04.2024
асинхронный канал внутри ngIf все еще получает значение
Я хочу написать складной компонент с кнопкой «Развернуть», открывающей список элементов. Этот список создается с помощью веб-запроса, и мне интересно, когда этот запрос произойдет - поскольку, насколько я понимаю, канал async похож на подписку, а...
30 просмотров
schedule
29.03.2022
RxJS-массив наблюдаемых HTTP-объектов: запускать следующий только после завершения предыдущего
У меня есть массив наблюдаемых (запросы HTTP POST), которые мне нужно отправить в API после определенного события. Ниже приведен упрощенный пример подхода, в котором я использую concat , чтобы использовать успешные, ошибочные и полные обратные...
72 просмотров
schedule
03.06.2022
ngIf Async Pipe как значение только с нулевой проверкой
У меня есть наблюдаемое, с которым я хотел бы создать переменную в ngIf, а также возвращать false, только если значение равно null (наблюдаемое возвращает число)
Мне нужно явно проверить значение null, поскольку мой наблюдаемый объект может...
857 просмотров
schedule
02.10.2022
Как использовать rxjs для нескольких внутренних вложенных подписок
В приведенном ниже коде я использовал подписку внутри подписки. Этот код работает, но структура кода очень плохая. Я хотел бы реорганизовать этот код с помощью rxjs( forkjoin или mergemap ). Я не знаю, как этого добиться. Может кто-то помочь мне с...
44 просмотров
schedule
23.12.2022
Наблюдаемый общий таймер обратного отсчета
У меня есть базовый наблюдаемый таймер, которым я хочу поделиться с несколькими подписчиками.
time = 30;
timer$ = timer(0,1000).pipe(
map(i => this.time - i),
take(this.time + 1),
finalize(() => console.log('DONE')),
share()...
268 просмотров
schedule
15.06.2022
