Вопросы по теме 'rxjs5'
Что может вызвать загрузку всех состояний магазина при изменении страницы?
Я использую ngrx / store , ngrx / effects и ngrx / router .
Мои эффекты такие:
@Effect() loadOneProduct$ = this.updates$
.whenAction(LOAD_ONE_PRODUCT)
.switchMap(() => this.productService.loadOneProduct())
.map(oneProduct...
672 просмотров
schedule
16.09.2021
Преобразование кода RxJS v4 в v5, обработка очереди с вытягиванием
---abcde-----f-------gh-----i----> //Events
У меня есть «рабочая очередь», за которой я хочу наблюдать / подписываться. Это массив командных объектов для обработки. Новые элементы работы обычно поступают пачками, и их необходимо...
179 просмотров
schedule
17.11.2021
Сериализовать массив в элементы, преобразовать с помощью RxJS и собрать элементы обратно в массив
В Angular2 у меня есть много Observable<any[]> (Observable, который испускает массивы), которые являются потомками http.get() или передаются через операции веб-сокета и, следовательно, не используют .complete () , но с течением времени...
501 просмотров
schedule
21.09.2021
Привязка обратного вызова функции Angular 2 и RxJs к this заставляет HTTP-запрос повторяться снова и снова
У меня есть метод обработки наших ошибок из HTTP-запросов, и он выглядит так
public handleError(err: any, caught: Observable<any>): Observable<any> {
//irrelevant code removed
this.logger.debug(err);//example of problem
return...
1503 просмотров
schedule
15.10.2021
В чем разница между Reactive-Extensions / RxJS и ReactiveX / rxjs
Я немного смущен. В чем разница между этими библиотеками? https://github.com/ReactiveX/rxjs https://github.com/Reactive-Extensions/RxJS В чем разница между rx , @ reactivex / rxjs rxjs на npm. Если вы ищете npm, есть несколько...
2846 просмотров
schedule
27.10.2021
couchdb; как получить документы непосредственно на первом уровне json, а не сгруппировать внутри значения - viewWithList
У меня есть проектный документ: «учетные записи» и представление: «учетные записи-просмотр».
содержание представления:
function (doc) {
emit( doc._id, doc);
}
И мой код в экспрессе:
db.view('accounts', 'accounts-view', function(err,...
257 просмотров
schedule
13.10.2021
Есть ли в RxJS противоположность оператору race?
У меня есть два наблюдаемых объекта, и я хочу послушать тот, который выдает свое первое значение последним, есть ли для этого оператор? Что-то подобное :
let obs1 = Rx.Observable.timer(500,500);
let obs2 = Rx.Observable.timer(1000,1000); // I...
1441 просмотров
schedule
11.10.2021
асинхронная труба с наблюдаемым в угловом 4
Я новичок в angular и начал склоняться к angular 4. Данные не связываются с директивой ngfor на компоненте, использующем асинхронный конвейер. Пожалуйста помоги
Пользовательский сервис использует HTTP-запрос для получения данных из API:...
1760 просмотров
schedule
11.10.2021
Как я могу удалить и добавить элемент в массив по индексу в способе RxJS?
Итак, у меня есть массив «событий»:
let events = Rx.Observable.from([1,2,3,4,5,6,7,8,9]);
Могу добавить (нажать):
let add = function(number){
events = events.concat([number]);
}
Я могу удалить:
let remove = function(){
events...
3238 просмотров
schedule
26.09.2021
Невозможно получить все данные при объединении двух наблюдаемых в rxjs
Я создал две наблюдаемые из базы данных:
const roomData$ = estab
.query()
.where('estab.type', 'like', 'rooms')
.then((rooms) => {
rooms.forEach((room) => {
observer.next(room.data);
});
});...
168 просмотров
schedule
27.10.2021
RxJS Obsevrable do () не вызывается
Почему функция do () не вызывается?
export class AppComponent implements OnInit {
name = 'Angular 5';
events = [];
existingEvents = [1,2,3,4,6]
ngOnInit() {
let i = 0;
this.events.push('Initial');
Observable.of(1,2,3,4,5)...
49 просмотров
schedule
14.09.2021
Как я могу иметь одновременно активными только X наблюдаемых?
Я использую RxJS v6, но ответ может относиться и к RxJS v5.
Я хотел бы сделать так, чтобы если бы я сказал 8 значений, у меня было бы только 4 активно обрабатываемых за раз.
Код, который у меня сейчас есть, отправляет 4 элемента, затем...
46 просмотров
schedule
25.11.2021
rxjs: получить дубликаты HTTP-запросов в первом отправляемом мною наборе
Я сделал эту функцию, на каждой итерации у меня есть 7 запросов, которые отправляют каждое время environment.dashboard.frequency, но в начале я вижу, что я отправляю на сервер 14 запросов вместо 7:
let requests: Observable<ResourceResponse>[]...
33 просмотров
schedule
29.10.2021
Наблюдаемый экземпляр испускает без наблюдателя (или подписчика?)
Я использую наблюдаемое в Angular2. Насколько я знаю до сих пор, каждый экземпляр Observable поставляется с наблюдателем (1: 1), и когда мы генерируем что-то с помощью Observable.next (value), мы можем получить это значение с помощью...
2148 просмотров
schedule
05.03.2022
Наблюдаемый, наконец, при подписке
Согласно этому artcle , onComplete и onError функция subscribe являются взаимоисключающими.
Это означает, что в моем subscribe будут запускаться события onError или onComplete . У меня есть логический блок, который должен выполняться...
113779 просмотров
schedule
08.03.2022
Возврат Observable ‹boolean› из метода обслуживания после разрешения двух подписок
Я пытаюсь настроить простой способ сравнения текущего имени пользователя с именем пользователя профиля в службе Angular.
Очевидно, что имя пользователя профиля и имя пользователя должны разрешиться, прежде чем я смогу их сравнить, так как мне...
28399 просмотров
schedule
14.03.2022
Тип Observable ‹any› не может быть назначен типу JSON в angular2 с помощью rxjs5
Я хочу изменить весь свой EventEmitter на Subjects, поскольку это рекомендуемый способ обмена переменными и состояниями вместо генерации события.
Но теперь у меня возникла проблема, и я просто не понимаю, как ее решить. Вот пример кода:...
951 просмотров
schedule
22.03.2022
объединение двух потоков наблюдаемых в RxJ в соответствии с определенными условиями
У меня есть два потока объектов, счета и балансы.
Мне нужно объединить (присоединить) два потока в соответствии с id и account_id
var accounts = Rx.Observable.from([
{ id: 1, name: 'account 1' },
{ id: 2, name: 'account 2' },
{...
3403 просмотров
schedule
19.03.2022
Отписаться от RxJS Observables
У меня есть эти два объекта, и я хочу перестать слушать их события. Я совершенно не знаком с наблюдаемыми объектами и RxJS и просто пытаюсь работать с библиотекой Inquirer .
Вот API RxJS для справки:...
13576 просмотров
schedule
04.04.2022
Создание бесконечного списка прокрутки в машинописном тексте с помощью rxjs5
Я пытаюсь создать список с бесконечной прокруткой, используя TypeScript и rxjs. То есть я хочу, чтобы приложение получало несколько страниц результатов из бэкэнда, а затем получало больше результатов всякий раз, когда пользователь прокручивает вниз....
1881 просмотров
schedule
11.04.2022