流星/ NG2：凡来处理需要两个订阅解决的可变

Question

假设我有

this.subscribe('a',() => {this.allA = A.find();}); 
this.subscribe('b',() => {this.allB= B.find();}); 

和可变这就是说，

let x = *take the first A, do some calculation to get the B linked, return B* 

如果这样的逻辑被治请确保仅在订阅“a”和“b”得到解决时才处理此问题。

可能会使用区域，但我不是100％什么可能是最好的方式来做@Component。

PS：避免做-A-服务器端法：d

问候

Answer 1

您可以使用forkJoin来 '结合' obsevables：

var rx = Observable.forkJoin(
    this.map(...), 
    this.map(...)) 

rx.subscribe(x => x.find()) 

细节和这里的例子https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/forkjoin.md

但是，这个问题很模糊，不清楚它引用了哪些技术。

Answer 2

而是在您的订阅使用回调，回归订阅手柄，然后再检查他们ready()状态：

const subA = this.subscribe('a'); 
const subB = this.subscribe('b'); 
const that = this; 

Tracker.autorun(()=>{ 
    if (subA.ready()) that.allA = A.find(); 
    if (subB.ready()) that.allB = B.find(); 
    if (subA.ready() && subB.ready()) { 
    let x = ... //compute x 
    } 
}); 

Answer 3

的解决方案似乎现在是将其包装在一个自动运行（MeteorComponent例如）

this.autorun(()=>{ 
    let s1 = this.subscribe('a',() => {this.allA = A.find();}); 
    let s2 = this.subscribe('b',() => {this.allB= B.find();}); 

    if(s1.ready() && s2.ready()) 
    ...