И
setTimeout 😊
Size: a a a
2021 June 25
OP
может timeoutWith?
S
events.pipe(debounceTime(...), switchMap(() => doSomething().pipe(takeUntil(events)))
OP
спасибо!
OP
еще можно вопрос - как вынести эту часть чтобы переиспользовать в другом потоке?
N👩
Советую посмотреть один замечательный доклад на эту тему от создателя RxJS:
https://www.youtube.com/watch?v=E6R_1QB8q4o
https://www.youtube.com/watch?v=E6R_1QB8q4o
OP
отлично!
N👩
Ну и короткий ответ на ваш вопрос:
function customOperator() {
return pipe(…)
}
OP
pipe() не находит
N👩
так, возможно неправильно подсказал
S
ну как бы пайп это метод потока
OP
ну да) тут поток надо запустить
S
дело не в запустить, вы можете его передать в аргументы и туда пайп закинуть
OP
так?
function test() {
return function<T>(source: Observable<T>) {
}
}
function test() {
return function<T>(source: Observable<T>) {
}
}
S
на самом деле я про другой костыль речь вел но тут лучше посмотреть доклад про кастомные операторы
OP
у меня на pipe ругается
Вキ
что ругает?
OP
все - надо было импортировать. вроде рботает