Вопросы по теме 'rxjs5'
Как один раз подписаться на эмиттер событий?
// Part of service
public someEvent: EventEmitter<number> = new EventEmitter();
....
// Component
@Component({
selector: 'some-component',
template: `...`
})
export class SomeComponent {
constructor(public service: Service) {...
24507 просмотров
schedule
05.10.2022
Подключить массив к Observable без .interval() в Angular2 Typescript
Есть ли способ сделать эту же функциональность без части "interval()"?
Я просто хочу подключить массив к наблюдаемому, а затем просто обновить массив и наблюдаемый объект, чтобы наблюдать за этим массивом и реагировать.
Если это хорошее решение,...
5292 просмотров
schedule
05.02.2024
Сбой Angular 2 RC4 RxJS
У меня есть фрагмент кода, который отлично работал до последнего обновления Angular 2. Помимо прочего, он использует Http-запросы и Observables.
Я обновился до RC4, импортировал все операторы RxJS (чтобы убедиться, что они работают) и получаю...
370 просмотров
schedule
25.01.2024
Subject‹any› поймайте методы подписки и отписки
Я хочу заставить тему rxjs иметь только одного подписчика за раз. и я хочу подсчитать количество подписок, чтобы обеспечить выполнение условия
import { Subject } from 'rxjs/Subject';
/**
* FormDialogActionModel
*/
export class...
635 просмотров
schedule
22.01.2024
Вилка соединяет две наблюдаемые базы данных firebase
Я использую angular2fire. Я спрашиваю и пытаюсь получить все туры из города.
getAllTours(cityId) {
return this.af.database.list(`/cities/${cityId}/tours`)
.map((tours): any => {
tours.map((tour: any) => {...
2141 просмотров
schedule
29.09.2022
Observable.forkJoin() не выполняется
У меня есть следующий код:
//Loop: For each user ID/Role ID, get the data
userMeta.forEach((businessRole) => {
Observable.forkJoin(
af.database.object('/roles/'+businessRole.$value),
af.database.object('/users/'+businessRole.$key)...
31092 просмотров
schedule
13.11.2023
RX-JS 5 — Использование подъема для регистрации наблюдаемых данных для отладки
Я новичок в RX-JS и хотел бы регистрировать данные для целей отладки. В конце концов, мне нужно регистрировать все наблюдаемые, определенные в фрагменте кода, и все события/испускания данных, происходящие из этих наблюдаемых.
Для RX-JS. Если я...
1244 просмотров
schedule
15.09.2022
как отменить и немедленно разрешить подписку в rxjs?
Новое в rxjs и angular2. Как прервать http-вызов и вернуть наблюдаемое, чтобы не получить ошибку в конце подписки? конечно, если я просто верну сюда объект, мы получим .searchAlbum(...).subscribe is not a function
public searchAlbum...
693 просмотров
schedule
28.05.2024
Переход с RxJS4 на RxJS5 — реализация Observer
В одном из моих проектов у меня есть следующий код, и после перехода на RxJS5 Rx.Observer больше не определяется:
let index = 0;
let obsEnqueue = this.obsEnqueue = new Rx.Subject();
this.queueStream = Rx.Observable.create(obs => {
var...
338 просмотров
schedule
03.12.2022
Получить параметр ActivatedRoute и queryParam в Angular 2
Каков наилучший способ получить весь контент URL-адреса в angular 2. В основном мне нужны параметры и параметры запроса. Сейчас я застрял здесь:
ngOnInit() {
this.activatedRoute.queryParams.subscribe(queryParam =>{
console.log(queryParam);...
498 просмотров
schedule
03.12.2022
Как преобразовать поток, читаемый узлом, в наблюдаемый RX
Если у меня есть поток Node js, скажем, из чего-то вроде process.stdin или из fs.createReadStream , как я могу преобразовать его в поток RxJs Observable, используя RxJs5?
Я вижу, что RxJs-Node имеет метод fromReadableStream , но похоже, что...
4950 просмотров
schedule
28.02.2024
Реактивное кэширование службы HTTP
Я использую RsJS 5 (5.0.1) для кэширования в Angular 2. Он работает хорошо.
Мясо функции кэширования:
const observable = Observable.defer(
() => actualFn().do(() => this.console.log('CACHE MISS', cacheKey))
)
.publishReplay(1,...
1566 просмотров
schedule
07.05.2024
Создайте сервис сердцебиения с помощью RxJS
Я хочу создать службу Heatbeat для своего веб-сайта angular2. Удаленное устройство является хостом веб-сайта, и клиент должен иметь возможность определить, недоступно ли устройство или находится в автономном режиме. Служба должна периодически...
2002 просмотров
schedule
26.11.2023
Почему триггер нажатия кнопки отличается от триггера setTimeout()?
Рассмотрим следующие, почти идентичные, два фрагмента.
Разница в следующем:
первый использует setTimeout() для запуска события
второй запускает событие при нажатии кнопки
Если вы посмотрите консоль, вы увидите, что последние две...
170 просмотров
schedule
13.01.2024
RxJS повторяет попытку получить данные после входа в систему - если вы вошли в систему, попробуйте один раз
У меня есть следующая проблема, которую я хочу решить с помощью RxJS (Angular 4)
если не войти в систему запрос данных не работает (403 запрещено)
если запрос завершается с ошибкой 403, я хочу повторить запрос данных, когда я вошел в систему...
45 просмотров
schedule
25.01.2024
Angular 2 — Проблема с картой переключения RxJS
Я пытаюсь иметь бесконечный раздел прокрутки в своем приложении. Для этого я использую этот компонент для обработки событий прокрутки и т. д. . Когда прокрутка достигает нижней части div, я вызываю функцию для получения дополнительных данных....
7689 просмотров
schedule
03.11.2022
Как работает канал RxJS (допустимые операторы)
Это на самом деле заметка для себя, но это может быть полезно для других.
Итак, вот 2 куска кода и мой вопрос в гиттере:
В чем разница между этими двумя?:
@Effect()
loadRegistrationsFailed$: Observable<Action> = this.actions$...
2318 просмотров
schedule
16.10.2022
RxJS и Angular HttpClient: как асинхронно преобразовать значение?
Я хочу применить функцию асинхронного преобразования к значению, испускаемому наблюдаемым.
@Injectable
export class ApiService{
constructor(private http: HttpClient){}
getSomething(url): Observable<any>{
return...
1872 просмотров
schedule
07.02.2024
BehaviorSubject: next не является функцией
Я пытаюсь обмениваться данными между одноуровневыми компонентами и делаю это через общую службу. Когда первый компонент загружается, он получает список серверов из моего API и заполняет поле выбора всеми полученными серверами. Теперь я хочу...
1879 просмотров
schedule
24.04.2024
Почему оператор switchMap выдает только последнее значение при использовании с обещанием?
У меня есть некоторые проблемы, чтобы понять это. Когда я использую оператор switchMap с Observable, он выдает все значения, как и ожидалось:
Observable.from([1, 2, 3, 4, 5])
.do(console.log)
.switchMap(i => Observable.of('*' + i))...
621 просмотров
schedule
21.11.2022
