rxjs map 参数是整个数组

Question

public observableA = (id: string): Observable<Array<any>>=>{

}

public observableB = (id: string): Observable<Array<myClass>>=>{
    observableA(metroId).map((x)=>{
         return new myClass(
            x.FacilityName,
            x.ID)
    };
}

export class myClass{
    ID: string;
    Name: string;
    constructor(id: string, name: string){this.ID=id;this.Name=name;}
}

ObservableA 返回一个对象数组，我正在编写一个函数 ObservableB 以使用返回的 ObservableA 数组返回一个 myClass 数组。

当我调试这段代码时， 我可以看到 map 参数中的“x”是来自 ObservableA 的整个数组，而不是数组的对象元素。

因此无法访问属性。

可能出了什么问题？

更新： 有没有办法将 Array 的单个 Observable 变成 Observable 的数组，以便我可以处理元素？

Answer 1

我认为你误解了 observables 的工作原理。

你得到了整个数组，因为这就是 observable 正在使用的。这是一个Observable<Array<any>>，所以map 运算符将得到一个Array<any>。如果你想一次处理一个对象，你的 observable 应该是 Observable<any> 类型（或者更好，使用像 Observable<TestClass> 这样的具体类）

您可以使用from 从Array<T> 创建Observable<T>，请参阅此页面： http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#static-method-from

我不知道这如何适用于你，因为你没有发布 observableA 的工作原理。

这是我学习 RxJs 时使用的一些资源：

• https://gist.github.com/staltz/868e7e9bc2a7b8c1f754
• https://toddmotto.com/rxjs-observables-observers-operators

Answer 2

我认为不需要第二个 Observable，也许这是您想要实现的，但如果我错了请告诉我，我会相应地更新：

live example

import { Observable } from 'rxjs/Observable';
import { async } from 'rxjs/scheduler/async';
import { from } from 'rxjs/observable/from';

import { map } from 'rxjs/operators';

const metroId: string = "IamAnId";
const arry: Array<myClass> = [];
const observableA: (id: string) => Observable<any> = (id: string) => {
    // use your id whatever you want
    return from([
        {
            FacilityName: 'name',
            ID: 'IamAnotherId'
        },
        {
            FacilityName: 'AnotherName',
            ID: 'AlsoHere'
        }
    ], asyn);
}

observableA(metroId)
    .pipe(map(x => {
        return new myClass(
            x.FacilityName,
            x.ID)
    }))
    .subscribe(itemClass => {
        arry.push(itemClass);
    })