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

Observable.from() в тестах angular 2 - ошибки внутри метода тестирования
Я должен использовать Observable в своих тестах и ​​этот небольшой код: it("should emit values", () => { const f = Observable.of([1, 3, 5]); f.subscribe(d => console.log(d)); }); дает следующую ошибку: TypeError: undefined...
591 просмотров
schedule 28.07.2023

Angular 2 RxJS проверяет, активно ли событие мыши после задержки
Я использую Angular 2 для создания директивы. У меня есть следующие события, связанные с хост-компонентом: host: { '(mouseenter)': 'onMouseEnter($event)', '(mouseleave)': 'onMouseLeave($event)' } Я также создал два потока и слушателя...
3224 просмотров
schedule 19.10.2022

Как сделать HTTP-запрос с интервалом?
Я совершенно новичок в angular и rxjs. Я пытаюсь создать приложение angular2, которое получает некоторые данные из статически обслуживаемого текстового файла (локально на сервере), которые я хотел бы получить и сопоставить с моделью данных, используя...
72703 просмотров
schedule 06.06.2023

асинхронный канал не отображает обновления потока
Попытка отобразить размер окна при изменении размера окна через поток в компоненте angular 2 с использованием канала async : <h2>Size: {{size$ | async | json}}</h2> const windowSize$ = new BehaviorSubject(getWindowSize());...
11636 просмотров

rxjs5 - фильтрация массива объектов по наблюдаемому, что каждый объект содержит
У меня есть массив, который выглядит так [ { name: 'foo' filter: Observable.of(true) }, { name: 'bar' filter: Observable.of(false) } ] и я хочу вернуть только элементы, filter которых разрешается в true, как мне...
3103 просмотров
schedule 24.05.2023

Правильный способ борьбы с ошибками, возникающими в onNext для горячих, общих, наблюдаемых
В RxJS версии 5 следующий код приводит к завершению процесса после трех итераций обеих подписок: var Rx = require("rxjs"); const published$ = Rx.Observable.interval(1000).publish(); published$.subscribe(index => { console.log(`One:...
864 просмотров

RxJS 5.0 делать пока как механизм
Я пытаюсь использовать RxJS для простого короткого опроса. Он должен делать запрос каждые delay секунд к местоположению path на сервере, заканчивая выполнением одного из двух условий: либо обратный вызов isComplete(data) возвращает true, либо...
2423 просмотров
schedule 04.09.2022

rxjs с angular2: в класс компонента, как преобразовать изменения данных поля ввода в поток rxjs
Сказано, что мы можем преобразовать что угодно в поток с помощью rxjs, здесь я хочу преобразовать данные, поступающие из поля ввода, в поток, а затем подписаться на него, в angular2 есть метод для этого с использованием события valueChanges...
1806 просмотров

RXJS5 против Promise.all
Есть ли эквивалент Promise.all? let prom1 = doA(); // some promise let prom2 = doB(); // another promise // wait for both promises to complete. Promise.all([prom1, prom2], values => { // do something; }); Не могу собрать его воедино...
170 просмотров
schedule 15.12.2023

Как правильно спроектировать подчиненных подписчиков, которые вызывают перезагрузку восходящего потока в RxJS?
Попытка построить расписание с использованием RxJS v5, где определенные события могут вызвать перезагрузку расписания. В настоящее время используются 3 источника — schedule$, event$ и userNotification$ (пример ниже). Я пробовал несколько разных...
161 просмотров
schedule 02.06.2022

Как остановить испускаемое значение, когда испускает другой наблюдаемый?
Имея два Observable, один из которых испускает событие mouseover (отклоняется на 500 мс), а другой - событие mouseout, я ищу возможность остановить первый Observable (mouseover) от испускания, когда происходит второй Observable (mouseout). let...
968 просмотров

Наблюдаемое событие сетевого плагина ionic 2 / rxjs5 / cordova
возможно ли каким-то образом сделать rxjs наблюдаемым с помощью fromEvent из подключаемого модуля сетевого подключения Cordova . Я пробую это с ionic 2. я вижу, что есть два события (онлайн / офлайн) в плагине сетевого подключения cordova ....
524 просмотров
schedule 07.04.2023

Переход с Angular2 beta1 на Angular2 beta15 — ошибка .map()
Я пытаюсь перенести проект с Angular2 beta1 на Angular2 beta15 , и у меня есть некоторые проблемы. У меня есть сообщение об ошибке: свойство map не существует в ответе Observable‹ >' Пример кода с этой ошибкой: import { Injectable }...
68 просмотров
schedule 20.10.2022

Использование RxJs и Angular 2 для обработки событий, отправленных сервером
Я пытаюсь отобразить значения, отправленные сервером, в приложении angular 2/RxJs. Серверная часть регулярно отправляет отдельные строки клиенту через события, отправленные сервером. Я не уверен, как обращаться с полученными значениями на...
15163 просмотров
schedule 22.04.2023

Создание RxJS Observable из (отправленного сервером) EventSource
Я хотел бы создать RxJs Observable из EventSource (события, отправленные сервером). Я пробовал следующее: import {Component, OnInit} from 'angular2/core'; import {Subject, Observable} from 'rxjs/Rx'; @Component({ selector: 'my-app',...
12334 просмотров
schedule 10.10.2023

Преобразуйте обычную строку[] в Observable‹string[]› и объедините ее с другой Observable‹string[]› с помощью RxJS 5
Я пытаюсь преобразовать обычный string[] в Observable<string[]> и объединить его с существующим Observable<string[]> . Затем я буду использовать канал angular2 async для отображения файла Observable . Вот мой код: import...
3476 просмотров
schedule 04.12.2022

Расширение метода с общим наблюдаемым в качестве возвращаемого типа
rxjs: 5.0.0-beta.2 Машинопись: 1.8 Angular2: бета-9 Я пытаюсь издеваться над классом обслуживания http, но сталкиваюсь с проблемами при расширении класса, как описано в документах angular 2. Похоже, вы не можете переопределить метод, который...
400 просмотров
schedule 28.08.2022

Как кэшировать и делиться ответом Http get()?
Следуя этому курсу https://www.pluralsight.com/courses/angular-2-getting-started и материалы github product.service в этом курсе пытается избежать вызова запроса http.get() каждый раз, когда я нажимаю на ссылку. Я думаю, что каждый раз загружать...
358 просмотров
schedule 18.11.2022

Невозможно создать циклическую зависимость
Я использую @ngrx/effects с @angular/router . (Угловая версия 2 RC4) Если я добавлю эту строку private router: Router в эффекты: @Injectable() export class RouterEffects { constructor( private updates$:...
3712 просмотров

Отменить наблюдаемое после первого раза - Angular2, TypeScript, rxjs/Observable
Я проверяю существующий логин при запуске приложения, что мне нужно только один раз. Как нам отменить эту подписку после первого раза? Я пробовал взять (1), но это не работает. this.auth.getUserData().take(1).subscribe(data => { // the...
6376 просмотров
schedule 21.03.2023