Rxjs 6平坦可观察

Question

我需要你的建议如何将Rxjs 5转换为Rxjs 6.

我的代码在下面,我不太清楚为什么它不起作用.

Rxjs 5

Observable.from([{amount:5},{amount:10}])
.flatMap(_ => depositService.deposit(depositAmount))
.toArray()
.subscribe(result => {
    console.log(result.length);
})

Rxjs 6

import { Observable, from, } from 'rxjs';
import { map, catchError, mergeMap} from 'rxjs/operators';
...

const source = from([{amount:5},{amount:10}]);
source
.pipe(mergeMap(_ => depositService.deposit(_.amount).toArray())
.subscribe(result => {
    console.log(result.length);
})

我收到了错误

您提供了一个无效的对象,其中包含一个流您可以提供Observable,Promise,Array或Iterable.

Answer 1

我认为toArray是一个操作符,应该在管道中传入.

import { Observable, from, } from 'rxjs';
import { map, catchError, mergeMap, toArray} from 'rxjs/operators';
...

const source = from([{amount:5},{amount:10}]);
source
.pipe(
    mergeMap(_ => depositService.deposit(_.amount)),
    toArray()
)
.subscribe(result => {
    console.log(result.length);
})