javascript - RxJS 超时不起作用

Question

当 Observable 流花费超过 3 秒时，我尝试退出它。问题是，当我多次复制并粘贴相同的值时，distinctUntilChanged 运算符不会让输入流通过。所以如果没有字符串流通过它，我想超时。这是我所拥有的。

        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";
        import "rxjs/add/operator/timeout";

        this._searchSubject
        .filter(val => val.length > 0)
        .debounceTime(500)
        .distinctUntilChanged()
        .timeout(3000)
        .switchMap(userSearchInput => {
            ...api call that returns Promise
        })
        .subscribe(searchResults => {
            ...do stuff with the result
        });

Answer 1

超时会引发TimeoutError，您正在处理此错误吗？

Rx.Observable.from(new Promise(resolve => setTimeout(resolve, 1000)))
  .timeout(500)
  .subscribe(console.log, ({ message }) => console.error(message));

或者，您可以使用 timeoutWith 和 Rx.Observable.empty() 结束流:

Rx.Observable.from(new Promise(resolve => setTimeout(resolve, 1000)))
  .timeoutWith(500, Rx.Observable.empty())
  .subscribe(null, null, () => console.log('done'));