Описание тега rxjs-pipeable-operators

Вопросы с тегом
1 ответ

Оператор карты возвращает целое число в качестве вывода с массивом в качестве ввода

Это пример кода из документов. Я новичок в RXJS, так что это может быть очень легко. Может кто-нибудь объяснить, как оператор карты возвращает однозначное целое число после работы с массивом? Я проверил, что возвращаемое значение оператора сканирова…
05 фев '19 в 14:49
2 ответа

Наблюдаемый, имеющий наблюдаемый член в шаблоне

У меня есть шаблон Angular 7, который представляет наблюдаемую book$ имея наблюдаемый translationsAsArray$ как участник: <div *ngIf="book$ | async as book"> <dl> <div *ngIf="(book.translationsAsArray$ | async) as translations"> &lt…
25 фев '19 в 16:07
1 ответ

Правильная защита типов пользовательских конвейерных операторов RxJS

Я работаю с API, который имеет фиксированную, непротиворечивую структуру ответов: это всегда объект, который имеет data собственность на это. Поскольку это очень утомительно и слишком явно, чтобы постоянно отображать данные в запросах RxJS (или эффе…
04 дек '18 в 08:52
1 ответ

Как я могу задержать наблюдаемое, только если оно возвращается быстрее, чем задержка

Взять, к примеру: this.http.get('/getdata').pipe(delay(2000)) Я хотел бы, чтобы этот запрос занимал как минимум 2 секунды, но не дольше, чем требуется для выполнения запроса. Другими словами: если запрос занимает 1 с, я хочу, чтобы наблюдаемое завер…
03 янв '19 в 22:33
2 ответа

Rxjs `DifferentUntilChanged()`, кажется, не работает

В потоке rxjs я использую distinctUntilChanged с Лодашем isEqual отфильтровать повторяющиеся значения. Однако, похоже, что он работает не так, как ожидалось. Возьмите следующий фрагмент кода import { isEqual } from 'lodash-es'; let cachedValue: any;…
24 фев '19 в 21:18
1 ответ

Как совместить ввод оператора и результат операции отсрочки вместе

Я попытался урезать мой вариант использования в примере ниже. Я застрял в точке, где мне нужно передать результат оператора, который должен иметь ввод передан оператором и результат операции отсрочки внутриconcatMap, так что я могу использовать его …
19 ноя '18 в 11:49
2 ответа

Как отменить ожидающий запрос во внутреннем HTTP, наблюдаемом с RXJS?

Отмена ожидающего HTTP-запроса при изменении страницы У нас есть служба Angular, которая имеет дорогой HTTP-запрос, доступ к которому могут получить 3 разных потребителя. Каждый потребитель может изменить этот запрос в любой момент, сделать новый за…
08 фев '19 в 16:44
0 ответов

Операторы RxJS - подписка не начинается с вложенных операторов

У меня есть следующий фрагмент кода, который не работает, как ожидалось. FooService имеет функцию с именем doFoo где он возвращает Observable, который никогда не подписывается правильно. В самом коде я оставил 2 строки, где они указывают, в какой мо…
03 дек '18 в 13:45
0 ответов

Невозможно отфильтровать уникальное значение с помощью diverUntilChanged() из входного потока

Нужна ваша помощь. Я новичок в мире Rxjs и пытаюсь использовать оператор DifferentUntilChanged (), чтобы избежать дублирования значений, полученных из потока через поле ввода. Но я не видел никакой разницы в выводе. Может быть, я неправильно понял о…
18 фев '19 в 06:47
1 ответ

Побочные эффекты только при использовании Pipeable Operators?

Я переписываю часть своего кода, чтобы использовать Pipeable Operators вместо операторов "patch", и меня немного смущает вопрос, когда использовать pipe() и как мне подписаться на пайп Observable "активировать" его, если я хочу только побочные эффек…
26 июн '18 в 14:48
3 ответа

Наблюдаемые операторы "что-то делают" через некоторое время

В цепочке наблюдаемых rxjs, как я могу сделать что-то с доступом к текущему значению наблюдаемой по истечении заданного количества времени? По сути, я ищу что-то вроде оператора tap, но он выполняется только в том случае, если прошло определенное ко…
27 сен '18 в 19:33
0 ответов

Где оператор 'do' на rxjs 6?

Мы медленно обновляемся с угловых 4 до 5, а затем 6. Итак, мы обновили rxjs. обычно я делал Observable.of(test').do(i=>console.log(i)) В новом rxjs я не могу найти оператор do что-то вроде: of('test') .pipe(do(i=>console.log(i) ) Как правильно?
03 сен '18 в 06:34
0 ответов

Зависимая цепочка наблюдаемых

Я использую ngrx/store и ngrx / Effects для управления глобальным состоянием внутри моего углового приложения. Поскольку у нас есть фиксированный API, мне пришлось реализовать некоторую логику в моем клиентском приложении. API имеет конечные точки д…
14 сен '18 в 09:28
1 ответ

Реализовать оператор RxJs вместо вложенных блоков подписки

Я получаю id из параметров маршрута и того, что я передаю в мой вызов API. Для этого я сейчас использую вложенную подписку. Но я хочу использовать concat() или, может быть, какой-то другой оператор RxJs(я не знаю, какой), чтобы я мог избежать вложен…
25 ноя '18 в 09:42
3 ответа

Труба RxJS не вызывается с молнией

Я заархивировал три наблюдаемые, каждая из этих трех имеет свой собственный обратный вызов "успеха", используя .pipe(tap() => {...});, Это прекрасно работает, когда все три наблюдаемые выполняются без ошибок, но если одна из наблюдаемых ошибок вы…
01 июн '18 в 17:33
3 ответа

RxJs Interval с takeUntil для публикации последнего значения

У меня есть код, который опрашивает, пока задача не будет завершена Увидеть ниже this.simulationStatus = interval(2000).pipe( switchMap( () => from(this.simulationService.getSimulationStatus(this.route.snapshot.paramMap.get('jobId')))), takeUntil…
09 авг '18 в 12:35
0 ответов

Проблема типа RxJS в подписке для конвейерных операторов

Я пытаюсь использовать конвейерные операторы RxJS в своем угловом проекте. У меня есть реализация, как показано ниже. // Service Method public getItems(params: Object = {}): Observable<JsendResponse> { return this.apiService.get('v1/url', para…
11 май '18 в 11:02
4 ответа

Как правильно отфильтровать массив в угловых

У меня есть сервисный лед, который извлекает массив из серверной части, мне нужно получить один элемент из массива на основе идентификатора, как мне это сделать в Angular? Я ищу, как это сделать конкретно с угловыми конвейерами. Фильтр, как правило,…
24 апр '18 в 12:55
0 ответов

Как объединить в 1 объект "родительский" (внешний) и "дочерний" (вложенный) запрос на выборку

1) У меня есть список (массив) URL-адресов для получения UserInfo. const userURLs = [ 'https://jsonplaceholder.typicode.com/users/1', 'https://jsonplaceholder.typicode.com/users/2', 'https://jsonplaceholder.typicode.com/users/3' ]; 2) После загрузки…
24 окт '18 в 15:06
2 ответа

Невозможно использовать операторы фильтра rxjs в angular4

Я пытаюсь использовать фильтр в угловых 4, это мой код import { Component, OnInit } from '@angular/core'; import { range } from 'rxjs/observable/range'; import { map, scan, filter, tap } from 'rxjs/operators'; @Component({ selector: 'app-root', temp…
28 ноя '18 в 21:23