Angular2 - 流れをキャンセル：観察可能 - > debounceTime - > mergeMap - >私はmergeMap方法で</p> <blockquote> <p>Observable -> debounceTime -> mergeMap -> subscribe</p> </blockquote> <p>流れをキャンセルするにはどうすればよい

Question

を購読しますか？

私はそのような何かを達成したい：

var request = this.listPartners.filterChange.asObservable() 
     .debounceTime(300) 
     .mergeMap(value => 
     { 
      if (value != "") 
       return this.partnersService.list({ filter: value }) //call http get 
      return null; 
     }); 
    if (request) 
     request.subscribe(partners => this.partners = partners); 

をしかし、私はエラーを取得する：

EXCEPTION: You provided 'undefined' where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.

私はmergeMapが...、アレイを観察可能返さなければなりませんが、私はしたくないということを理解しますvalue == ""の場合はサーバーに要求してください。どうやって？

編集：

私の最初のコード（リターンヌルなし）であった：

コール return;と同じですが、私は return null、 return;または何を呼び出すと例外は、同じである

var request = this.listPartners.filterChange.asObservable() 
     .debounceTime(300) 
     .mergeMap(value => 
     { 
      if (value != "") 
       return this.partnersService.list({ filter: value }) 
     }); 
    if (request) 
     request.subscribe(partners => this.partners = partners); 

。ジャイのasnwerため

編集：

var request = this.listPartners.filterChange.asObservable() 
     .debounceTime(300) 
     .mergeMap(value => 
     { 
      if (value != "") 
       return this.partnersService.list({ filter: value }) 
      return; 
     }); 
    console.log("request", request);  //this is not called if (value == "") 
    if (request) 
     request.subscribe(partners => this.partners = partners); 

Answer 1

あなたはそれが動作していないこと

var request = this.listPartners.filterChange.asObservable() 
     .debounceTime(300) 
     .filter((value)=> value!='') /// will stop the rest if the value is '' 
     .mergeMap(value => 
     { 
      if (value != "") 
       return this.partnersService.list({ filter: value }) //call http get 
      return null; 
     }); 
    if (request) 
     request.subscribe(partners => this.partners = partners); 

Answer 2

だけreturn;代わりにヌルを返す：

// return null; 
return; 

---

現在、あなたがやってチェックしているとあなたは、いくつかのproperyで観察を返すことができますそのプロパティが空白でない場合：

var request = this.listPartners.filterChange.asObservable() 
    .debounceTime(300) 
    .mergeMap(value => this.partnersService.list({filter: value })); 

if (request.filter !== "") 
    request.subscribe(partners => this.partners = partners); 

Answer 3

mergeMap関数ではnullを返すことはできません。

返されます。

var request = this.listPartners.filterChange.asObservable() 
    .debounceTime(300) 
    .mergeMap(value => 
    { 
     if (value != "") 
      return this.partnersService.list({ filter: value }) //call http get 
     return; 
    }); 
if (request) 
    request.subscribe(partners => this.partners = partners);