RxJSマップOberservableをフィルタリングする方法

Question

現在、RxJSでMap Observableをフィルタリングすることで苦労しています。 私がしようとするのは、それを購読する前にフィルタ関数でマップオブジェクトを減らすことです。

私はこのような件名をINIT：

public myObjects: ReplaySubject<Map<number, MyClass>> = new ReplaySubject<Map<number, MyClass>>(1); 

そして、それは私がフィルタリングしようとする方法は次のとおりです。

public subscribeToIncomingObjects() { 
this.myObjects.map((currentValue:Map<number, MyObject>) => Array.from(currentValue.values())).filter(
    (con:myObject, index) => { 
    return someCondition; 
    } 
); 
} 

詐欺はArray型ではなく、単一のインスタンスであるいくつかの理由。私は本当に助言に感謝します。

Answer 1

まず第一に、物事、

あなたはObservableを扱っている：

this.myObjects.map((currentValue:Map<number, MyObject>) => Array.from(currentValue.values())) 

はObservable<MyObject[]>を返します。したがって、.filter()をObservableと呼ぶと、Observableのブロードキャストをフィルタリングしています。

あなたはこのようなあなたのフィルタを呼び出すことができます：あなたはまだあなたが単一のインスタンスが必要な場合、それが利用可能な場合、あなたがより良いArray.prototype.find()を使用したい、配列になるだろう

public subscribeToIncomingObjects() { 
    this.myObjects.map((currentValue: Map < number, MyObject >) => { 
    return Array.from(currentValue.values()) 
     .filter((con: myObject, index) => someCondition); 
    }); 
} 

しかし：

public subscribeToIncomingObjects() { 
    this.myObjects.map((currentValue: Map < number, MyObject >) => { 
    return Array.from(currentValue.values()) 
     .find((con: myObject, index) => someCondition); 
    }); 
} 

か、まだArray.prototype.filter()を使用して：

public subscribeToIncomingObjects() { 
    this.myObjects.map((currentValue: Map < number, MyObject >) => { 
    return Array.from(currentValue.values()) 
     .filter((con: myObject, index) => someCondition)[0]; 
    }); 
}