typescript - 如何枚举同步可观察对象？

Question

例如，如果您有一个可观察的 from(['a', 'b']) , 如何获得发出 [0, 'a'] 的可观察对象和 [1, 'b'] ？

我试过了from('a', 'b').pipe(zip(range(0, Number.POSITIVE_INFINITY))) ，但这会造成无限循环:如果您尝试 Rx.Observable.from(['a', 'b']).zip(Rx.Observable.range(0, Number.POSITIVE_INFINITY)).do(console.log).subscribe()在控制台中(提示:页面 http://reactivex.io/rxjs/manual/overview.html 已经导入了 Rx)，这将导致页面挂起(range 正在无限期地推送值)。在我的上下文中(使用 IndexedDB)我不能使用异步调度程序，而且无论如何从性能的角度来看它都没有意义。

我通过创建自定义运算符解决了这个问题

import { Observable } from 'rxjs/Observable';
import { map } from 'rxjs/operators';

export const enumerate = <T>(source: Observable<T>) => {
  let index = 0;
  return source.pipe(map(source => ({ value: source, index: index++ })));
};

但我是否缺少更简单的解决方案？奇怪的是 RxJS 有这个陷阱......

Answer 1

许多运营商一直在为您计算 index 作为另一个参数传递给回调函数:

from(['a', 'b']).pipe(
  map((value, index) => [ index, value ]))
);

或者如果你想发射对象:

map((value, index) => ({ index, value }))