Вопросы по теме 'rxjs-pipeable-operators'
Как импортировать ErrorObservable или _throw в rxjs6? добавить rxjs
Я перехожу на rxjs 6.0.0-ucandoit-rc.6 . В версии 5.5.2 я использовал ErrorObservable для создания наблюдаемого с ошибками.
Я использовал способ, рекомендованный здесь: https://github.com/ReactiveX/rxjs/blob/master/doc/pipeable-operators.md...
7732 просмотров
schedule
23.07.2022
Трубка RxJS без молнии
Я заархивирую три наблюдаемых объекта, у каждой из трех наблюдаемых есть собственный обратный вызов "успеха" с использованием .pipe(tap() => {...}); . Это отлично работает, когда все три наблюдаемых объекта выполняются без ошибок, но если одна из...
1522 просмотров
schedule
18.10.2023
Отправлять второе действие после завершения первого действия из компонента в NGRX / RXJS
Я новичок в использовании NGRX / RXJS в моем приложении angular, и у меня есть ситуация, когда мне нужно отправить действие из моего компонента, который извлекает данные из API, если свойство пусто и обновляет Store_1 и устанавливает свойство, а затем...
3936 просмотров
schedule
06.06.2022
Интервал RxJs с takeUntil для публикации последнего значения
У меня есть код, который опрашивает до тех пор, пока задача не будет завершена
Смотри ниже
this.simulationStatus =
interval(2000).pipe(
switchMap(
() =>...
2434 просмотров
schedule
07.01.2023
Где оператор «делать» на rxjs 6?
Мы медленно обновляем angular 4 до 5, а затем 6. Итак, мы обновили rxjs. обычно я делал
Observable.of(test').do(i=>console.log(i))
В новых rxjs я не могу найти оператор do, например:
of('test')
.pipe(do(i=>console.log(i)
)...
1994 просмотров
schedule
07.05.2024
Как объединить наблюдаемый параметр запроса и наблюдаемую форму с помощью Angular и RXJS
У меня есть список сообщений с разбиением на страницы, на который я подписываюсь на параметр запроса ?page= , чтобы отозвать API службы.
ngOnInit(): void {
this.route.queryParams.subscribe(params => {
const page =...
515 просмотров
schedule
04.11.2022
Почему карта не работает после обновления RxJS до v6.3
У меня есть случай, аналогичный описанному в этом посте .
У меня есть служба входа в систему, которая (среди прочего) проверяет, действителен ли токен пользователя. Ответ сервера определяется в интерфейсе:
export interface UserVerifyResponse...
35 просмотров
schedule
19.02.2022
Как я могу отложить наблюдаемое, только если оно возвращается быстрее, чем задержка
Возьмем, к примеру:
this.http.get('/getdata').pipe(delay(2000))
Я хочу, чтобы этот запрос занимал минимум 2 секунды, но не дольше, чем это требуется для выполнения запроса.
Другими словами:
если для выполнения запроса требуется 1...
473 просмотров
schedule
16.11.2022
Rxjs `distinctUntilChanged()` не работает
В потоке rxjs я использую distinctUntilChanged с isEqual lodash для фильтрации повторяющихся значений. Однако он похоже работает не так, как ожидалось. Возьмите следующий фрагмент кода
import { isEqual } from 'lodash-es';
let cachedValue:...
7450 просмотров
schedule
29.07.2022
Наблюдаемый поток, значения которого обогащены другими, одноразовыми наблюдаемыми объектами
У меня есть вспомогательная функция, которая выполняет вызов API и возвращает массив items . Каждый из этих элементов представляет собой сущность, скажем, User .
У каждого пользователя есть свойство category_id , которое по умолчанию имеет...
210 просмотров
schedule
14.10.2022
RxJS не выдает ошибку при отображении, даже если базовый наблюдаемый выдает ошибку
У меня есть сетевой вызов, при котором вероятно, что api выдаст ошибку 400. Я хочу с этим справиться.
Прямо сейчас я делаю это так, как показано ниже -
private fetchStatus(objectId: string): Observable<string> {
return...
75 просмотров
schedule
10.07.2022
В чем разница между throttleTime и debounceTime в RxJS и когда выбирать?
Я пытаюсь понять throttleTime vs debounceTime и какой из них использовать, когда?
У меня есть кнопка "за", которая делает запрос API к бэкэнду (который подсчитывает голоса). Пользователь может отправить кнопку несколько раз, но я бы хотел...
6957 просмотров
schedule
26.05.2022
Как исправить вложенную подписку, чтобы она работала последовательно?
Я пытаюсь несколько раз подписаться на свой собственный бэкэнд. Пока мой код извлекает данные, что-то, похоже, работает неправильно. При выполнении следующего кода все отображается так, как должно быть, кроме последовательности. Таким образом, мои...
65 просмотров
schedule
18.04.2024
Есть ли разница между фильтром (cond) и flatMap (x = ›cond? Of (x): EMPTY)?
Я пытаюсь понять, в чем разница между этими двумя наблюдаемыми. Единственная разница в коде заключается в следующем:
/**
* Inside rxjs pipe
*/
if(typeof x === 'number' && x > 3) {
return of(x);
} else {
return EMPTY;
}
vs:...
34 просмотров
schedule
02.06.2022
Когда вы подписываетесь на rxjs, как вы сигнализируете своему тесту, если он терпит неудачу?
Я полный новичок. Проблема, с которой я столкнулся, заключается в том, что как только я выдаю ошибку в наблюдаемом rxjs, мой тест не знает об этом. Когда я подписываюсь на тест, и он терпит неудачу в rxjs, он просто выдает ошибку, и мне нужно...
64 просмотров
schedule
07.11.2022
Как правильно throwError и в чем смысл различных ловушек ошибок в Angular HTTP
Я провел довольно много исследований, прежде чем решил опубликовать вопросы здесь. Мои знания о том, как Angular (или вообще) обрабатывает ошибку HTTP, очень туманны, поэтому я ищу некоторые разъяснения/предложения.
Для простоты предположим, что у...
73 просмотров
schedule
05.04.2023
Кэшировать Http-запросы, используя только операторы RxJS
Я пытаюсь добиться того, что описано здесь: https://www.prestonlamb.com/blog/rxjs-cache-and-refresh-in-angular
Другими словами, я хочу кэшировать наблюдаемое в течение заданного времени (скажем, 1 минуту). Когда подписка осуществляется после...
882 просмотров
schedule
04.04.2023
Как установить текущий индекс или двигаться назад, хотя наблюдаемый rxjs?
Я использую наблюдаемую rxjs для моделирования последовательности шагов, которые происходят в моем приложении.
Псевдокод
const steps = [{id: "step1"}, {id: "step2"}, {id: "step3"}]
//... then at some point later do things based on the steps...
124 просмотров
schedule
16.08.2022
Оператор взятия() RxJS
У меня возникли проблемы с пониманием оператора take(). В его определении предполагается, что он возвращает первое значение, испускаемое наблюдаемым, но мне кажется, что оно возвращает последнее.
Я попробовал следующий тест, чтобы понять это лучше:...
162 просмотров
schedule
02.07.2023
Убедитесь, что существует минимальная временная задержка между событиями
Я получаю некоторые данные по частям и хочу обработать точки данных с минимальным временным расстоянием. (Вы можете сформулировать это как throttleTime без потери данных или как противоположность buffer ). После тонны попыток и поисков в Google я...
29 просмотров
schedule
15.07.2022
