Как я могу использовать несколько debounceTime для одного наблюдаемого?

Question

У меня есть входной HTML элемент и делает основной вид вперед функция поиска с помощью Наблюдаемые:

Код:

@Output() keywordChange = new EventEmitter(); 

    this.keyword$ = Observable.fromEvent(myInput, 'keyup'); 
    this.keyword$ 
     .map((event: any) => event.target.value) 
     .debounceTime(200) 
     .subscribe(keyword => this.keywordChange.emit(keyword)); 

Поэтому в основном я захватить все ключевые слова, набранные с по меньшей мере 200 мс между каждым KeyUp.

Теперь я хочу сохранить все, что пользователь ищет в файле cookie, чтобы показать им «Ваши последние поисковые запросы», но я хочу подождать 3000 мс до сохранения введенных значений.

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

this.keyword$ 
     .map((event: any) => event.target.value) 
     .debounceTime(200) 
     .subscribe(keyword => this.keywordChange.emit(keyword)) 
     .debounceTime(3000) 
     .subscribe(keyword => addKeyWordToLatestSearches(keyword)); 

Возможно ли это каким-то образом, цепочки операторов, чтобы сделать несколько вещей с разными debounceTimes?

Answer 1

Возможно, вы хотите получить share первоначальную подписку, чтобы иметь возможность обрабатывать испускаемые данные двумя независимыми способами? Поскольку вы не хотите подписываться дважды в исходном источнике, вы можете использовать share operator RxJS.

const keyupValue$ = this.keyword$ 
    .map((event: any) => event.target.value) 
    .share(); 

keyupValue$ 
    .debounceTime(200) 
    .subscribe(keyword => this.keywordChange.emit(keyword)) 

keyupValue$ 
    .debounceTime(3000) 
    .subscribe(keyword => addKeyWordToLatestSearches(keyword));