javascript - Rxjs 使用 Observable.from() 字符串并防止 Observable 被多次创建

Question

我有以下函数，我试图阻止每次调用该函数时创建 Observable。基本上，每次用户在搜索字段中键入内容时都会调用此函数。我知道我可以从事件创建 Observable 作为 Observable.fromEvent('button', click) ，但这需要我对应用程序进行大量更改。如有任何帮助，我们将不胜感激。

function search(input) { 
  Observable.from([input])
  .map(value => value)
  .filter(value => value.length >3)
  .debounceTime(300)
  .distinctUntilChanged()
  .switchMap(searchValue => { 
    //ajax call 
    return Promise.resolve(data) 
  }) 
  .subscribe(data => {
    //Do something with the data
  })
}

Answer 1

如果您想使用可观察对象，但不想从事件创建可观察对象，则可以创建一个 Subject 并可以从您的对象中调用其 next 方法搜索:

import { Subject } from 'rxjs/Subject';
import 'rxjs/add/operator/filter';
import 'rxjs/add/operator/debounceTime';
import 'rxjs/add/operator/distinctUntilChanged';
import 'rxjs/add/operator/switchMap';

var searchSubject = new Subject();
  .filter(value => value.length > 3)
  .debounceTime(300)
  .distinctUntilChanged()
  .switchMap(searchValue => { 
    // ajax call
    return Promise.resolve(data) 
  }) 
  .subscribe(data => {
    // Do something with the data
  });

function search(input) { 
  searchSubject.next(input);
}