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

RxJS5: как отображать и фильтровать за один раз - как «собирать» в Scala?
В моем кодировании Scala я нашел метод collect довольно полезным. Это позволяет одновременно фильтровать и преобразовывать элементы. В RxJS вроде ничего такого нет. Я пропустил что-то очевидное, или это считается ненужным? Помощник, который...
67 просмотров
schedule 04.10.2022

Использование Rxjs5 (бета-версия) для ограничения HTTP-запросов
Я использую RxJS5 ( https://github.com/ReactiveX/RxJS ) и пытаюсь для доступа к Riot API, который имеет ограничение в 500 запросов каждые 10 минут и 10 запросов каждые 10 секунд. Я настроил поток объектов запроса, и у меня есть подписчик, готовый...
90 просмотров
schedule 16.02.2023

Не могу найти `combLatest` в RxJS 5.0
Следующий код вызывает у меня Observable.combineLatest is not a function при использовании RxJS 5.0: let Observable = require('rxjs/Observable.js').Observable; import 'rxjs/add/operator/combineLatest'; Observable .combineLatest([player,...
14789 просмотров
schedule 04.02.2023

Подсчет нажатий клавиш в секунду с угловым 2 Rxjs
/** * Created by darius on 02/04/16. */ import { Component } from 'angular2/core'; import { Observable } from 'rxjs/Rx'; @Component({ styles: [ require('../../style.css') ], selector: 'keypresses-per-second', template: ` <div...
1331 просмотров
schedule 16.07.2022

Как запустить .next() во второй раз в асинхронной теме rxjs?
У меня есть компонент с двумя кнопками. Когда я нажимаю первую кнопку в соответствии с демонстрацией в данном плункере ниже, он генерирует событие, и моя сервисная функция испускает асинхронную тему с некоторыми значениями... Когда я нажимаю другую...
846 просмотров
schedule 13.09.2022

получение ошибок rxjs при ссылке на последние rxjs
Я использую этот учебник https://egghead.io/lessons/rxjs-creating-an-observable , который ссылается на версию 2.5.2 rxjs. Я ссылаюсь на последний rx.umd.js из [email protected]" пакета npm <script...
2654 просмотров
schedule 05.04.2023

Не удается найти модуль «rxjs/subject/BehaviorSubject»
Я использую Ангуляр 2. Когда я использую любой из этих двух, моя программа работает хорошо: import { BehaviorSubject } from 'rxjs/Rx'; import { BehaviorSubject } from 'rxjs'; Тем не менее, я пытаюсь использовать следующий способ:...
32207 просмотров
schedule 31.05.2022

Пакеты @reactivex/rxjs и rxjs NPM для RxJS 5
В @reactivex/rxjs пакете предлагается использовать пакет с областью действия: npm установить @reactivex/rxjs И модуль UMD доступен через npmcdn как https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js Тем не...
1070 просмотров
schedule 07.07.2023

Разница между «новым BehaviorSubject» и «BehaviorSubject.create»
Я использую Angular 2 и RxJS 5. Есть ли разница между этими двумя: И что использовать в первую очередь? Спасибо isOpen$ = new BehaviorSubject<boolean>(true); а также isOpen$ = BehaviorSubject.create(true);
4145 просмотров
schedule 11.08.2022

Продолжайте откладывать HTTP-запрос до тех пор, пока не поступят новые параметры
Предположим, у нас есть функция getIds(), которая принимает массив некоторых идентификаторов, например: getIds([4, 1, 32]); Эта функция задержит вызов HTTP на 100 мс. Но в течение 100 мс, если эта же функция будет вызвана снова:...
55 просмотров
schedule 30.12.2022

Объедините два ответа ajax в RXJS
Я все еще изучаю RXJS (только начал), я знаю, что мой вопрос будет для начинающих. Я пытаюсь объединить два ответа от внешнего вызова. Скажем, я делаю call1 и call2, и у меня должна быть возможность подписаться одним комбинированным ответом. Ниже...
846 просмотров
schedule 13.08.2023

Как установить контекст для функции обратного вызова подписки rxjs?
У меня такая подписка: this.test.subscribe(params => { ...some code }); Если я передаю функцию обратного вызова вместо функции стрелки, контекст отсутствует. Я хочу связать контекст с функцией подписки, но я этого...
5646 просмотров
schedule 01.11.2022

Rxjs: какой сценарий вы хотите использовать планировщик
Я не понимаю, что означает планировщик в документации rxjs, поэтому я пытаюсь понять по сценарию, в котором он полезен, чтобы я мог понять планировщик
516 просмотров

RxJS — использование windowWhen() для окон maxWait и maxElements
Я пытаюсь связать вызовы с сервером с максимальным значением maxEntries, но не хочу ждать дольше, чем maxWait ms. Раньше это было доступно как windowWithTimeOrCount() в RxJS 4, но было удалено из RxJS 5. Все отлично работает, за исключением...
270 просмотров
schedule 30.06.2022

Невозможно прочитать свойство 'type' неопределенного (ngrx)
Я использую ngrx. Я получил ошибку Невозможно прочитать свойство "тип" неопределенного Это часть моих кодов: @Effect() foo$ = this.actions$ .ofType(Actions.FOO) .withLatestFrom(this.store, (action, state) => ({ action,...
2553 просмотров
schedule 25.01.2024

RxJs 5 периодический опрос с неупорядоченным обновлением
У меня есть следующий код (httpObservable завершается при первом выпуске), который опрашивает службу с фиксированным «мертвым временем»: return serviceObservable.expand(() => Observable.timer(period).concatMap(() => serviceObservable));...
127 просмотров
schedule 18.12.2022

Observable Продолжайте вызывать API и изменять параметры в зависимости от условия
Я прочитал повторение Rx.js , чтобы узнать, как я могу продолжайте вызывать API на основе ответа, который я получаю от API . Я вызываю API , который может отправлять только 2k записей за раз. API вернет мне значение для отправки, чтобы я мог...
5188 просмотров
schedule 25.06.2022

rxjs дроссель this.durationSelector не является функцией
Я пытаюсь throttle ngrx хранить события обновления действий со следующим кодом import 'rxjs/add/operator/throttle' import { Dispatcher, Store } from '@ngrx/store'; ... static get parameters() { return [[Dispatcher]]; } constructor(actions$) {...
4467 просмотров
schedule 29.04.2024

Как вызвать метод кеша для Observables в rxjs
Я новичок в rxjs. Я хотел знать, правильный ли код ниже или требуется какое-либо исправление? var rxjs_1 = require('rxjs'); rxjs_1.Observable.defer(function() { }) .cache(1); В приведенном выше коде я столкнулся...
829 просмотров
schedule 05.04.2023

RxJs. Как дождаться другого наблюдаемого, если он сработал недавно
В основном у меня есть две подписки, которые время от времени запускают события. Первый довольно простой, он загружает и отображает некоторые данные: observableOne$.switchMap(event => { return loadData(event); }).subscribe(data => {...
501 просмотров
schedule 25.08.2022