आरएक्सजेएस

Question

के साथ वादा .all() मैं कोणीय 2 में एक ऐप लिख रहा हूं और मैं कई http अनुरोध निष्पादित करना चाहता हूं और प्रतिक्रियाओं पर एक फ़ंक्शन चलाता हूं।

कोणीय 1 में, मैं $q.all([$http.get(...), $http.get(...), ...]).then(doSomethingWithResponses);

लेकिन जैसे कुछ लिखते थे कोणीय 2 रिटर्न RxJS observables और पढ़ने का एक गुच्छा मैं अभी भी समझ नहीं कई HTTP अनुरोधों की प्रतिक्रियाएं प्राप्त करने के लिए के बाद। यह कैसे किया जा सकता है?

Answer 1

जैसा @Eric Martinez ने बताया, forkJoin है। फोर्कजोइन समानांतर में सभी अवलोकन अनुक्रम चलाता है और अपने अंतिम तत्व एकत्र करता है।

Rx.Observable.forkJoin([a,b]).subscribe(t=> { 
     var firstResult = t[0]; 
     var secondResult = t[1]; 
}); 

Answer 2

मुझे यकीन है कि आप forkJoin/zip का उपयोग करना चाहते हैं, विशेष रूप से विचार कर combineLatest समझने के लिए और प्रत्येक उप-धारा उत्सर्जित होने पर प्रत्येक उप-धारा घटना पर फेंकना होगा, जबकि forkJoin मूल रूप से नमूने आसान है नहीं कर रहा हूँ।

यह बाद में आपको काटने के लिए आ सकता है जब आप सड़क के नीचे बहु-वस्तु पर्यवेक्षकों को जोड़ना चाहते हैं।

Answer 3

मैं RxJS सीख रहा हूँ और मैं RxJS v5 के साथ एक ही बात करने के लिए

ऐसा लगता है जैसे हम v5 पर forkJoin अब और नहीं है कोशिश कर रहा था, इसलिए यहाँ है मैं कैसे मिला यह काम कर रहा (flatMap या साथ काम करता है mergeMap, जो कर रहे हैं उपनाम):

const callOne = value => 
    new window.Promise(resolve => 
     setTimeout(() => resolve(value + 10), 3000) 
    ); 

const callTwo = value => 
    new window.Promise(resolve => 
     setTimeout(() => resolve(value + 20), 1000) 
    ); 

Rx.Observable 
    .of(2) 
    .do(() => console.log('querying...')) 
    .mergeMap(number => 
     Rx.Observable.zip(
      Rx.Observable.fromPromise(callOne(number)), 
      Rx.Observable.fromPromise(callTwo(number)) 
     ) 
    ).concatAll() 
    .subscribe(createSubscriber('promises in parallel')); 

Answer 4

चाहेंगे नहीं एक merge काम करता है? आप onComplete कॉलबैक पर एक हैंडलर सब्सक्राइब और संलग्न कर सकते हैं।

मैं पहली बार मेरी observables की एक सरणी का निर्माण और उसके बाद स्थिर merge का उपयोग करें: //www.syntaxsuccess:

let obs_ary: any = [obs1, obs2, obs3]; 
Observable.merge(...obs_ary);