Observableで複数のdebounceTimeを使用するにはどうすればよいですか？

Question

私は入力html要素を持っており、基本的なタイプが先に観測を使用して機能を検索すること：

コード：だから基本的に私はそれぞれの間で少なくとも200ミリ秒で入力した任意のキーワードをキャプチャしてい

@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)); 

キーアップ。

これで、「最新の検索」を表示するために、ユーザーがCookieで検索しているものはすべて保存しますが、保存する前に3000ミリ秒待っています。 値が入力されました。

は、私は次のコードは動作しません知っているが、ただ、私はこれに似何かを達成したい示すために：異なるdebounceTimesで複数の物事を行うための演算子をチェーン、

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

は何とかこのことは可能ですか？

Answer 1

放出されたデータを2つの独立した方法で処理する可能性があるため、最初のサブスクリプションはshareでしょうか？元のソースで2回購読したくないので、RxJSのshare operatorを使うことができます。

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));