[RxJS] AsyncSubject

var subject = new Rx.AsyncSubject();
var delayedRange = Rx.Observable.range(0,5).delay(1000);

delayedRange.subscribe(subject);

//----[0,1,2,3,4]|
//  AsyncSubject
//----4|

subject.subscribe(
  function onNext(item) { console.log(‘Value:‘, item); },
  function onError(err) { console.log(‘Error:‘, err); },
  function onCompleted() { console.log(‘Completed.‘); }
)

/*
"Value:"
4
"Completed."
*/

function getProducts(url){
  var subject;
  
  return Rx.Observable.create(function(observer){
    //If first time, then create AsyncSubject
    if(!subject){
      subject = new Rx.AsyncSubject();
      //Subscribe to subject
      Rx.DOM.get(url).subscribe(subject);
    }
    //If subject already exists, then just subscribe observer
    return subject.subscribe(observer);
  })
}

var products = getProducts(‘/products‘);

// Will trigger request and receive the response when read
products.subscribe(
  function onNext(result) {console.log(‘Result 1: ‘, result.response)},
  function onError(error) {console.log(‘ERROR‘, error)}
);

// Will receive the result immediately because it is cached
setTimeout(function(){
  products.subscribe(
    function onNext(result) {console.log(‘Result 2: ‘, result.response)},
    function onError(error) {console.log(‘ERROR‘, error)}
  )
}, 5000)