Описание тега rxjs6
RxJS6 - это версия 6 реактивных расширений для JavaScript с некоторыми добавленными изменениями в веб-сокете, тестировании и исправлениях ошибок.
0
ответов
RxJS 6 буфер с откровением в качестве закрытия Notifier
Как мне реализовать мои Observables, чтобы получить следующее поведение в RxJS 6? RxMarble диаграмма Описание: я пытаюсь создать буфер [1] для входящих значений Observable[0], который буферизуется после времени debounce[2] того же Observable[0]. Это…
16 окт '18 в 13:24
3
ответа
Angular - RxJS - Как выполнить действия для отфильтрованных элементов в цепочке?
У меня есть труба, как это: this.parentFormControl.valueChanges .pipe( debounceTime(500), distinctUntilChanged(), tap(() => { this.focusIndex = -1; }), filter(() => this.myCondition()), switchMap((value: string) => { return this.http.get(va…
08 окт '18 в 15:53
2
ответа
Я не получаю rxjs 6 с угловым 6 с интервалом, switchMap и map
Я хочу обновить свой код rxjs до 6, я не получаю его. До того, как я провел нижеследующий опрос на новые данные каждые 5 секунд: import { Observable, interval } from 'rxjs'; import { switchMap, map } from 'rxjs/operators'; var result = interval(5000…
06 май '18 в 14:35
1
ответ
Рекурсивно построить JSON до n-го уровня для древовидного представления с помощью операторов RXJS
Я пытаюсь построить древовидное представление n-уровня с помощью rxjs. Я достиг того же самого с простым JavaScript. Найти код JS здесь var x = [{"id":1,"name":"Admin","parentDepartmentId":null},{"id":2,"name":"Development","parentDepartmentId":1},{…
22 май '18 в 10:52
0
ответов
Используя RxJS `generate` для создания не дрейфующего таймера, как использовать` планировщик`?
В поисках таймера - запускаемого каждую минуту, каждую минуту - который не дрейфует, я нашел это решение. Однако у меня возникают трудности с пониманием, как использовать / построить последний параметр scheduler?: SchedulerLike, const noDrift = gene…
10 ноя '18 в 15:04
1
ответ
Как объединить два наблюдаемых. Rx 6.2.2
У меня есть два вызова к бэкэнду, и мне нужно обрабатывать результат только тогда, когда оба ответа будут готовы: this.historyService.fetchBalance().subscribe((balance: Balance[]) => { this.servicesBalance = balance; }); this.historyService.fetch…
12 сен '18 в 00:41
1
ответ
Изменить вложенные наблюдаемые значения
return this.http.get(environment.remoteUrl + '/client').pipe(pluck('rows'), map((i: any) => i.doc)); Я получаю данные в следующей структуре: { rows: [ {x: 123, doc: {a: 2}}, {x:222, doc: {a: 1}} ], c: 'hello', b: 3 } Я только верну подписчику оба…
31 июл '18 в 12:15
1
ответ
Объединяет последний не огонь из-за поведения субъекта?
Следующий код взят из моего сервисного компонента. Это требует, чтобы пользователь наблюдал и данные отправляли в BehaviorSubject. Я звоню form.service.formToSubmit$.next(form); обновить его. потому что CombineLatest также срабатывает, когда пользов…
02 окт '18 в 14:24
1
ответ
Преобразование карты rxjs 5 в карту rxjs 6
Рассмотрим следующий код Angular 5 + старше rxjs this.measurementUnitsService.GetAll().subscribe( res => { this.measurementUnits = res.map(x => new MeasurementUnit(x)); } ) Я получаю список объектов и для каждого из них создаю новый строго тип…
14 авг '18 в 18:24
1
ответ
RxJS HTTP-клиент: тип ответа для не JSON
Я не уверен, в чем здесь проблема. Я хотел бы сделать HTTP-запрос, который отвечает на двоичные данные (например, загрузка файла) вместо JSON. import {HttpClient, HttpHeaders, HttpParams} from "@angular/common/http"; Эти строки в порядке - но ожидай…
22 авг '18 в 21:29
2
ответа
Как сделать несколько HTTP-вызовов в Angular6, используя forkJoin и ngrx?
сценарий В моем приложении angular6 у меня есть три категории: catA, catB, catC. Каждая категория нуждается в данных от 3 API. При нажатии на любую категорию он загружает компонент CategoryDetailsComi, и я отправляю действие (LoadCategoryDetails). …
26 сен '18 в 15:06
1
ответ
Angular 6 можно подписаться на подписку
Я не совсем понимаю, как правильно обращаться с наблюдаемым. Так что у меня проблема с моим кодом. В сервисе у меня есть два метода: verify(): Observable<any> { return this.http.post(some_url); } // and isAuthenticated(){ this.verify().subscri…
18 май '18 в 14:05
1
ответ
Angular: текстовый поиск rxjs проблема
Я создаю поиск в Angular 6, Мне тяжело с моим потоком. Я хочу, чтобы мой поток RX: Принимает изменения ввода текста Объединить с subject который сообщает потоку, чтобы получить больше результатов (предел приращения) при нажатии кнопки Позвоните в се…
05 сен '18 в 19:01
1
ответ
Отправка действия каждую секунду с помощью наблюдаемого редукса
С равниной RxjsМне удалось реализовать поведение "обратного отсчета", вызывая метод каждую секунду, как это, пока не осталось больше времени: const time = 5 var timer$ = Rx.Observable.interval(1000) timer$ .take(time) .map((v)=> { const remaining…
31 янв '19 в 09:03
1
ответ
HttpClient GET преобразовать ответный массив объектов
Ниже моя модель. export interface AuditTrail { logAction:string, targetEmpId:string, createdDate:Date } Код ниже извлекает данные из вызова GET и преобразует их. public getAuditTrails() { return this.http.get<AuditTrail[]>(this.auditTrailUrl) …
02 фев '19 в 18:57
0
ответов
RxJS "объединить" не удается с обещаниями
Я пытаюсь объединить результат API-вызовов для приложения React через merge а также from наблюдаемые операторы, подобные этому: import { from, merge } from 'rxjs'; import { map, scan } from 'rxjs/operators'; merge( from( new Promise(function(resolve…
03 авг '18 в 14:41
1
ответ
Как использовать наблюдаемое в `filter`?
Предположим, у меня есть структура каталогов, подобная следующей: foo | +---one | +---tmp | +---two | +---three | +---tmp Я хочу получить список подкаталогов под foo который имеет tmp (под) подкаталог внизу. У меня есть следующий код, который делает…
15 июл '18 в 06:49
1
ответ
Как использовать RxJs 6 с TypeScript и WebPack
Я следовал этому уроку (очень просто): https://www.techiediaries.com/rxjs-tutorial/ Мой index.ts выглядит так: import { Observable, Observer } from "rxjs"; import { map } from "rxjs/operators" console.log(Observable); var observable = Observable.cre…
18 ноя '18 в 09:15
2
ответа
angular6 RxJs проблема наблюдаемых
Я пытаюсь получить список задач из класса обслуживания в компоненте. Но это не работает. Пожалуйста, найдите код ниже: todos.service.ts import { Injectable } from '@angular/core'; import { Todos } from '../models/Todos'; import { HttpClient, HttpHea…
06 сен '18 в 18:18
1
ответ
rxjs zip два switchMap?
У меня есть определено поведение Subject: measurementSearchChange$ = new BehaviorSubject(''); this.measurementSearchChange$ .asObservable() .pipe(debounceTime(500)) .pipe( switchMap((keyword: string) => this.warningService.getInfluxdbQuery( this.…
06 июл '18 в 01:47