对于在TypeScript中使用Angular2编写的Web应用程序,我需要使用RxJs Observable.
由于我之前从未使用过rxjs,而且我一般都是反应编程的新手,所以我有时候在找到正确的方法来做一些特定的事情时会遇到一些困难.
我现在面临一个问题.在哪里我必须转换Array<Observable<T>>为Observable<Array<T>>.
我将尝试用一个例子来解释它:
- 我有一个Observable,它给了我一个Users(Observable<Array<User>>)的列表
- User-class有一个函数getPosts返回一个Observable<Array<Post>>.
- 我需要将a映射Observable<Array<User>>到a Observable<Array<Post>>来评估函数Post内的所有s onNext.
我可以轻松地映射Observable<Array<User>>到Observable<Array<Observable<Array<Post>>>>使用
map((result : Array<User>) => result.map((user : User) => user.getPosts()))
ans我可以将一个Array<Array<Post>>变成一个Array<Post>.
但是我只是找不到正确的方法来映射Observable<Array<Observable<Array<Post>>>>到一个Observable<Array<Array<Post>>>
直到现在我combineLatest一起使用该功能flatMap.
对我来说它似乎工作,我使用的编辑器(Atom编辑器)没有显示任何错误.但是现在我使用Netbeans,它在这段代码中显示错误.使用"tsc"编译代码也会导致错误.
看起来像这样:
Argument of type '(result: Post[]) => void' is not assignable to parameter of type 'NextObserver<[Observable<Post>]> …