RXJS एक सरणी में सभी observables के लिए प्रतीक्षा करें पूरा करने के लिए (या त्रुटि)

Question

मैं ऐसे जैसे एक सरणी में observables धक्का हूँ ...

var tasks$ = []; 
tasks$.push(Observable.timer(1000)); 
tasks$.push(Observable.timer(3000)); 
tasks$.push(Observable.timer(10000)); 

मैं एक नमूदार चाहते का उत्सर्जन करता है कि जब सभी कार्य पूरा कर लिया है $। ध्यान रखें, व्यावहारिक रूप से, कार्यों में $ अवलोकन योग्य संख्या नहीं है।

मैंने Observable.zip(tasks$).subscribe() को आजमाया है, लेकिन ऐसा लगता है कि केवल 1 कार्य है, और यह मुझे विश्वास करने के लिए प्रेरित कर रहा है कि ज़िप को उम्मीद है कि जिस तरह से मैं अपेक्षा करता हूं, उसमें काम करने के लिए ज़िप की भी आवश्यकता है।

मैंने Observable.concat(tasks$).subscribe() की कोशिश की है लेकिन कॉन्सट ऑपरेटर का नतीजा सिर्फ अवलोकनों की एक सरणी है ... उदा। मूल रूप से इनपुट के समान ही। आप इस पर सब्सक्राइब भी नहीं कर सकते हैं।

सी # में यह कार्य के समान होगा। जब सभी()। ईएस 6 में वादा करता है कि यह Promise.all() के समान होगा।

मैं कई सारे प्रश्नों में आया हूं लेकिन वे सभी ज्ञात संख्याओं (जैसे उन्हें एक साथ मैपिंग) पर प्रतीक्षा करने का सामना करते हैं।

Answer 1

आप का उत्सर्जन करता है कि जब स्रोत के सभी पूरा observables एक नमूदार रचना करना चाहते हैं, तो आप forkJoin उपयोग कर सकते हैं:

import { Observable } from 'rxjs/Observable'; 
import 'rxjs/add/observable/forkJoin'; 
import 'rxjs/add/operator/first'; 

var tasks$ = []; 
tasks$.push(Observable.timer(1000).first()); 
tasks$.push(Observable.timer(3000).first()); 
tasks$.push(Observable.timer(10000).first()); 
Observable.forkJoin(...tasks$).subscribe(results => { console.log(results); }); 

Answer 2

मुझे इस sample के लिए सबसे अच्छा समाधान था।

const source = Observable.interval(500); 
const example = source.sample(Observable.interval(2000)); 
const subscribe = example.subscribe(val => console.log('sample', val)); 

तो .. केवल जब दूसरा (उदाहरण) का उत्सर्जन - आप पहली बार (स्रोत) के अंतिम उत्सर्जित मूल्य देखेंगे।

मेरे कार्य में, मैं फॉर्म सत्यापन और अन्य डोम ईवेंट का इंतजार करता हूं।