typescript - RxJS 将 Observable 转换为 Observable

Question

RxJS 5.5.6。我正在尝试转换 Observable<string[]>进入Observable<string>

我不确定 mergeAll运算符是我要找的

const o1: Observable<string[]> = of(['a', 'b', 'c']);
const o2: Observable<string> = o1.pipe(
  mergeAll()
);

Typescript 将返回此错误:

Type 'Observable<string | string[]>' is not assignable to type 'Observable<string>'.
  Type 'string | string[]' is not assignable to type 'string'.
    Type 'string[]' is not assignable to type 'string'.

我接收 Observable 作为参数，我可以改变构造方式。

Answer 1

您似乎遇到了一个已报告的 RxJS 问题，请参阅 https://github.com/ReactiveX/rxjs/issues/2759甚至最近https://github.com/ReactiveX/rxjs/issues/3290 .

从评论来看，它似乎要到 RxJS 6 才能修复。

但是，您始终可以使用 mergeMap(o => o)/concatMap(o => o) 而不是 mergeAll()/concatAll().

例如:

const o1: Observable<string[]> = of(['a', 'b', 'c']);
const o2: Observable<string> = o1.pipe(
  mergeMap(o => o)
);