let promise = new Promise((resolve, reject) => {
  setTimeout(() => {
    resolve('Promise completed');
  }, 2000);
});

promise.then(result => console.log(result)); 
// 2 सेकंड के बाद कंसोल 'प्रॉमिस पूर्ण' दिखाएगा।

let observable = new Observable(observer => {
  setTimeout(() => {
    observer.next('First callback');
    setTimeout(() => {
      observer.next('Second callback');
      observer.complete();
    }, 2000);
  }, 2000);
});

let subscription = observable.subscribe(result => console.log(result)); 
// 2सेकंड के बाद कंसोल 'First callback' शो करेगा
// फिर 2सेकंड के बाद 'Second callback' दिखायेगा
// किसी भी समय आप उपसर्जन को 'subscription.unsubscribe();' के साथ रोक सकते हैं

let subject = new Subject();
  subject.next(1); //किसी भी निरीक्षक द्वारा प्राप्त नहीं किया जाएगा
  subject.subscribe((value) => console.log(value)); // भविष्य के उत्सर्जन के लिए सदस्यता लेता है
  subject.next(2); // '2' प्रिंट करेगा

let subject = new BehaviorSubject(1); // '1' के मान के साथ आरंभ होता है
  subject.subscribe((value) => console.log(value)); // सदस्यता के तुरंत बाद '1' प्रिंट करता है
  subject.next(2); // '2' प्रिंट करेगा

let subject = new ReplaySubject(2); // अंतिम 2 मान संग्रहित करेगा
  subject.next(1);
  subject.next(2);
  subject.next(3);
  subject.subscribe((value) => console.log(value)); // '2', '3' प्रिंट करेगा

let subject = new AsyncSubject(); // केवल अंतिम मान जारी करेगा और केवल पूर्ण होने पर
  subject.next(1);
  subject.next(2);
  subject.subscribe((value) => console.log(value)); // अभी तक कुछ भी प्रिंट नहीं करेगा
  subject.next(3);
  subject.complete(); // चूंकि ऑपरेशन पूरा हो चुका है, यह अंतिम मान जारी करेगा। '3' प्रिंट करेगा